Python 请求：POST JSON 和文件（多格式数据）在 1 个请求中
Python Requests: POST JSON and file (multiform data) in 1 single request
从客户端（使用 python）我想发送 json 数据和文件作为使用 multiform-data 的单个请求的一部分，但无法实现。在服务器端，我有 Jersey，如果我使用 curl 发送请求，它工作正常，但如果使用 Python 发送相同的请求，那么它不会工作，因为 Jersey 崩溃。
python-请求包版本 0.8.2-1。我无法升级到最新版本，因为这是 ubuntu 12.04.
可用的最新版本
below curl 请求工作正常，服务器能够使用 below curl 成功处理请求。
curl -v -k -u "test:" -F file=@/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 发送，键名作为 '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)
这是我尝试安装的 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'
作为 requests.post() 的一部分发送文件和数据参数对我不起作用，所以我最终做的是将 json 数据作为输入流发送。我在 Python 端将 JSON 数据转换为 StringIO，然后将 StringIO 对象作为 "files" 参数中的另一个文件对象发送，在服务器端，我将其作为 InputStream 接收，我将其转换为 JSON获取所需值的对象。
服务器上的球衣代码：
@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))
从客户端（使用 python）我想发送 json 数据和文件作为使用 multiform-data 的单个请求的一部分，但无法实现。在服务器端，我有 Jersey，如果我使用 curl 发送请求，它工作正常，但如果使用 Python 发送相同的请求，那么它不会工作，因为 Jersey 崩溃。
python-请求包版本 0.8.2-1。我无法升级到最新版本，因为这是 ubuntu 12.04.
可用的最新版本below curl 请求工作正常，服务器能够使用 below curl 成功处理请求。
curl -v -k -u "test:" -F file=@/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 发送，键名作为 '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)
这是我尝试安装的 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'
作为 requests.post() 的一部分发送文件和数据参数对我不起作用，所以我最终做的是将 json 数据作为输入流发送。我在 Python 端将 JSON 数据转换为 StringIO，然后将 StringIO 对象作为 "files" 参数中的另一个文件对象发送，在服务器端，我将其作为 InputStream 接收，我将其转换为 JSON获取所需值的对象。
服务器上的球衣代码：
@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))