2015-05-26 40 views
0

從客戶端(使用Python)我想發送兩個JSON數據和文件作爲單一請求的一部分使用multiform-data但無法實現這一點。在服務器端,我有Jersey,如果我使用curl發送請求,那麼它工作正常,但如果使用Python發送相同的請求,那麼當Jersey發生崩潰時它不起作用。Python請求:POST JSON和文件(多種形式的數據)在一個單一的請求

python-requests package version 0.8.2-1。我無法升級到最新版本,因爲這是適用於Ubuntu 12.04的最新版本。

低於curl請求正常工作,服務器能夠以低於curl成功處理請求。

curl -v -k -u "test:" -F [email protected]/tmp/test_new.zip --form upload_info='{"id": "1234", "test": "testing"}' -X POST "https://IP/test_api" 

的片段服務器端代碼

@POST 
    @Path("/test_api") 
    @Consumes(MediaType.MULTIPART_FORM_DATA) 
    @Produces(MediaType.APPLICATION_JSON) 
    public Response testAPIHandler(
        @HeaderParam("Authorization") String auth, 
        @FormDataParam("file") InputStream uploadedInputStream, 
        @FormDataParam("file") FormDataContentDisposition fileDetail, 
        @FormDataParam("upload_info") JSONObject jsonData) throws IOException { 
      try { 
        id = jsonData.getString("id"); 
        url = jsonData.getString("test"); 
       } 

這是本Python代碼,但不起作用。甚至試圖發送upload_info作爲嵌套json的keyname作爲'upload_info',也沒有工作。

def test_upload(): 
    url = "https://IP/api/test_api" 
    user = "test" 
    passwd = None 
    upload_info = {'id': '1234', 'test': "testing"} 
    filepath = "/tmp/test_new.zip" 
    json_data = simplejson.dumps(upload_info) 

    fileobj = open(filepath, 'rb') 
    files = {'file' : ('test_new.zip', fileobj)} 

    headers = {'Content-type': 'multipart/form-data'} 
    r = requests.post(url, files=files, data=json_data, auth=(user, passwd), headers=headers) 

    print r.status_code 

test_upload() 

當我使用Python發送請求我得到的服務器端此異常

May 25, 2015 9:35:03 PM com.sun.jersey.spi.container.ContainerResponse mapMappableContainerException 
SEVERE: The RuntimeException could not be mapped to a response, re-throwing to the HTTP container 
java.lang.NullPointerException 
    at com.sun.jersey.multipart.impl.MultiPartReaderClientSide.unquoteMediaTypeParameters(MultiPartReaderClientSide.java:227) 
    at com.sun.jersey.multipart.impl.MultiPartReaderClientSide.readMultiPart(MultiPartReaderClientSide.java:154) 
    at com.sun.jersey.multipart.impl.MultiPartReaderServerSide.readMultiPart(MultiPartReaderServerSide.java:80) 
    at com.sun.jersey.multipart.impl.MultiPartReaderClientSide.readFrom(MultiPartReaderClientSide.java:144) 
    at com.sun.jersey.multipart.impl.MultiPartReaderClientSide.readFrom(MultiPartReaderClientSide.java:82) 
    at com.sun.jersey.spi.container.ContainerRequest.getEntity(ContainerRequest.java:488) 
    at com.sun.jersey.spi.container.ContainerRequest.getEntity(ContainerRequest.java:552) 
    at com.sun.jersey.multipart.impl.FormDataMultiPartDispatchProvider$FormDataInjectableValuesProvider.getInjectableValues(FormDataMultiPartDispatchProvider.java:122) 
    at com.sun.jersey.server.impl.model.method.dispatch.AbstractResourceMethodDispatchProvider$EntityParamInInvoker.getParams(AbstractResourceMethodDispatchProvider.java:153) 
    at com.sun.jersey.server.impl.model.method.dispatch.AbstractResourceMethodDispatchProvider$ResponseOutInvoker._dispatch(AbstractResourceMethodDispatchProvider.java:203) 
    at com.sun.jersey.server.impl.model.method.dispatch.ResourceJavaMethodDispatcher.dispatch(ResourceJavaMethodDispatcher.java:75) 
    at com.sun.jersey.server.impl.uri.rules.HttpMethodRule.accept(HttpMethodRule.java:302) 
    at com.sun.jersey.server.impl.uri.rules.RightHandPathRule.accept(RightHandPathRule.java:147) 
    at com.sun.jersey.server.impl.uri.rules.ResourceClassRule.accept(ResourceClassRule.java:108) 
    at com.sun.jersey.server.impl.uri.rules.RightHandPathRule.accept(RightHandPathRule.java:147) 
    at com.sun.jersey.server.impl.uri.rules.RootResourceClassesRule.accept(RootResourceClassesRule.java:84) 
    at com.sun.jersey.server.impl.application.WebApplicationImpl._handleRequest(WebApplicationImpl.java:1511) 
    at com.sun.jersey.server.impl.application.WebApplicationImpl._handleRequest(WebApplicationImpl.java:1442) 
    at com.sun.jersey.server.impl.application.WebApplicationImpl.handleRequest(WebApplicationImpl.java:1391) 
    at com.sun.jersey.server.impl.application.WebApplicationImpl.handleRequest(WebApplicationImpl.java:1381) 
    at com.sun.jersey.spi.container.servlet.WebComponent.service(WebComponent.java:416) 
    at com.sun.jersey.spi.container.servlet.ServletContainer.service(ServletContainer.java:538) 
    at com.sun.jersey.spi.container.servlet.ServletContainer.service(ServletContainer.java:716) 
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:722) 
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305) 
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210) 
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:224) 
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:169) 
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472) 
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:168) 
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:98) 
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118) 
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:407) 
    at org.apache.coyote.ajp.AjpProcessor.process(AjpProcessor.java:200) 
    at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:579) 
    at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:307) 
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) 
    at java.lang.Thread.run(Thread.java:745) 
+0

您能撥打電話沒有文件,只是使用參數其他一些資源的方法? – Raghuveer

回答

1

發送文件和數據PARAM作爲requests.post()的一部分,我沒有工作,所以我落得這樣做是要發送的JSON數據作爲輸入流。我在Python端將JSON數據轉換爲StringIO,然後將StringIO對象作爲「文件」參數中的另一個文件對象發送,並在服務器端將其作爲InputStream接收,然後將其轉換爲JSONObject以獲取所需的值。

服務器澤西代碼:

@POST 
    @Path("/test_upload_files") 
    @Consumes(MediaType.MULTIPART_FORM_DATA) 
    @Produces(MediaType.APPLICATION_JSON) 
    public Response testHandler(
        @HeaderParam("Authorization") String auth, 
        @FormDataParam("file") InputStream uploadedInputStream, 
        @FormDataParam("file") FormDataContentDisposition fileDetail, 
        @FormDataParam("json_data") InputStream jsonStream) throws IOException { 
      String encoding = "UTF-8"; 
      JSONObject jsonObject; 

      StringWriter writer = new StringWriter(); 

      IOUtils.copy(jsonStream, writer, encoding); 

      String input = writer.toString(); 

      try { 
        jsonObject = new JSONObject(input); 
        id = jsonObject.getString("id"); 
        country = jsonObject.getString("country"); 
      } catch (JSONException e) { 
        return null; 
      } 

    } 

下面是Python代碼發送:

import simplejson 
import requests 
from cStringIO import StringIO 

def upload_files_and_json(): 
    url = "https://IP/test_upload_files" 
    user = "foo" 
    passwd = None 
    upload_info = {'id': '1234', 'country': 'zzz'} 
    filepath = "/tmp/test.zip" 
    json_data = simplejson.dumps(upload_info) 
    json_input = StringIO(json_data) 

    fileobj = open(filepath, 'rb') 
    files = {'file' : ('test.zip', fileobj), 'json_data': json_input} 

    r = requests.post(url, files=files, auth=(user, passwd)) 
0

這裏是我試圖安裝requests

import requests  

class RestCall: 

    if __name__ == '__main__': 

     url = "http://url.com/rest/doj/webservice/helloge" 

     data = dict(fn='Test', ln='Me') 

     r = requests.post(url, data=data, allow_redirects=True) 
     print (r.content) 

您的服務器組件看起來像下面

@POST 
@Path("/helloge") 
@Produces("text/plain") 
public String helloGe(@FormParam("fn") String fn,@FormParam("ln") String ln){ 
    return "Hello "+fn+" "+ln;  
} 

您的輸出是:

b'Hello Test Me' 
+0

FormParam在Jersey 1.17中沒有,並且發送文件和數據都不起作用。 –

+0

您甚至可以根據您的需要使用JAXRS,並且使用綁定工具可以使生活變得更加輕鬆。無論如何也用答案更新您的代碼,以便其他人可以參考它。 – Raghuveer