最近在工作中遇到一個(gè)需求，就是要開(kāi)一個(gè)接口來(lái)接收供應(yīng)商推送的數(shù)據(jù)。項(xiàng)目采用的python的django框架，我是想也沒(méi)想，就直接一梭哈，寫(xiě)出了如下代碼：
class XXDataPushView(APIView):
"""
接收xx數(shù)據(jù)推送
"""
# ...
@white_list_required
def post(self, request, **kwargs):
req_data = request.data or {}
# ...
但隨后，發(fā)現(xiàn)每日數(shù)據(jù)并沒(méi)有任何變化，質(zhì)問(wèn)供應(yīng)商是否沒(méi)有做推送，在忽悠我們。然后對(duì)方給的答復(fù)是，他們推送的是gzip壓縮的數(shù)據(jù)流，接收端需要主動(dòng)進(jìn)行解壓。此前從沒(méi)有處理過(guò)這種壓縮的數(shù)據(jù)，對(duì)方具體如何做的推送對(duì)我來(lái)說(shuō)也是一個(gè)黑盒。
因此，我要求對(duì)方給一個(gè)推送的簡(jiǎn)單示例，沒(méi)想到對(duì)方不講武德，仍過(guò)來(lái)一段沒(méi)法單獨(dú)運(yùn)行的java代碼：
private byte[] compress(JSONObject body) {
try {
ByteArrayOutputStream out = new ByteArrayOutputStream();
GZIPOutputStream gzip = new GZIPOutputStream(out);
gzip.write(body.toString().getBytes());
gzip.close();
return out.toByteArray();
} catch (Exception e) {
logger.error("Compress data failed with error: " + e.getMessage()).commit();
}
return JSON.toJSONString(body).getBytes();
}
public void post(JSONObject body, String url, FutureCallbackHttpResponse> callback) {
RequestBuilder requestBuilder = RequestBuilder.post(url);
requestBuilder.addHeader("Content-Type", "application/json; charset=UTF-8");
requestBuilder.addHeader("Content-Encoding", "gzip");
byte[] compressData = compress(body);
int timeout = (int) Math.max(((float)compressData.length) / 5000000, 5000);
RequestConfig.Builder requestConfigBuilder = RequestConfig.custom();
requestConfigBuilder.setSocketTimeout(timeout).setConnectTimeout(timeout);
requestBuilder.setEntity(new ByteArrayEntity(compressData));
requestBuilder.setConfig(requestConfigBuilder.build());
excuteRequest(requestBuilder, callback);
}
private void excuteRequest(RequestBuilder requestBuilder, FutureCallbackHttpResponse> callback) {
HttpUriRequest request = requestBuilder.build();
httpClient.execute(request, new FutureCallbackHttpResponse>() {
@Override
public void completed(HttpResponse httpResponse) {
try {
int responseCode = httpResponse.getStatusLine().getStatusCode();
if (callback != null) {
if (responseCode == 200) {
callback.completed(httpResponse);
} else {
callback.failed(new Exception("Status code is not 200"));
}
}
} catch (Exception e) {
logger.error("Get error on " + requestBuilder.getMethod() + " " + requestBuilder.getUri() + ": " + e.getMessage()).commit();
if (callback != null) {
callback.failed(e);
}
}
EntityUtils.consumeQuietly(httpResponse.getEntity());
}
@Override
public void failed(Exception e) {
logger.error("Get error on " + requestBuilder.getMethod() + " " + requestBuilder.getUri() + ": " + e.getMessage()).commit();
if (callback != null) {
callback.failed(e);
}
}
@Override
public void cancelled() {
logger.error("Request cancelled on " + requestBuilder.getMethod() + " " + requestBuilder.getUri()).commit();
if (callback != null) {
callback.cancelled();
}
}
});
}
從上述代碼可以看出，對(duì)方將json數(shù)據(jù)壓縮為了gzip數(shù)據(jù)流stream。于是搜索django的文檔，只有這段關(guān)于gzip處理的裝飾器描述:
django.views.decorators.gzip 里的裝飾器控制基于每個(gè)視圖的內(nèi)容壓縮。
如果瀏覽器允許 gzip 壓縮，那么這個(gè)裝飾器將壓縮內(nèi)容。它相應(yīng)的設(shè)置了 Vary 頭部，這樣緩存將基于 Accept-Encoding 頭進(jìn)行存儲(chǔ)。
但是，這個(gè)裝飾器只是壓縮請(qǐng)求響應(yīng)至瀏覽器的內(nèi)容，我們目前的需求是解壓縮接收的數(shù)據(jù)。這不是我們想要的。
幸運(yùn)的是，在flask中有一個(gè)擴(kuò)展叫flask-inflate，安裝了此擴(kuò)展會(huì)自動(dòng)對(duì)請(qǐng)求來(lái)的數(shù)據(jù)做解壓操作。查看該擴(kuò)展的具體代碼處理：
# flask_inflate.py
import gzip
from flask import request
GZIP_CONTENT_ENCODING = 'gzip'
class Inflate(object):
def __init__(self, app=None):
if app is not None:
self.init_app(app)
@staticmethod
def init_app(app):
app.before_request(_inflate_gzipped_content)
def inflate(func):
"""
A decorator to inflate content of a single view function
"""
def wrapper(*args, **kwargs):
_inflate_gzipped_content()
return func(*args, **kwargs)
return wrapper
def _inflate_gzipped_content():
content_encoding = getattr(request, 'content_encoding', None)
if content_encoding != GZIP_CONTENT_ENCODING:
return
# We don't want to read the whole stream at this point.
# Setting request.environ['wsgi.input'] to the gzipped stream is also not an option because
# when the request is not chunked, flask's get_data will return a limited stream containing the gzip stream
# and will limit the gzip stream to the compressed length. This is not good, as we want to read the
# uncompressed stream, which is obviously longer.
request.stream = gzip.GzipFile(fileobj=request.stream)
上述代碼的核心是:
request.stream = gzip.GzipFile(fileobj=request.stream)
于是，在django中可以如下處理：
class XXDataPushView(APIView):
"""
接收xx數(shù)據(jù)推送
"""
# ...
@white_list_required
def post(self, request, **kwargs):
content_encoding = request.META.get("HTTP_CONTENT_ENCODING", "")
if content_encoding != "gzip":
req_data = request.data or {}
else:
gzip_f = gzip.GzipFile(fileobj=request.stream)
data = gzip_f.read().decode(encoding="utf-8")
req_data = json.loads(data)
# ... handle req_data
ok, 問(wèn)題完美解決。還可以用如下方式測(cè)試請(qǐng)求：
import gzip
import requests
import json
data = {}
data = json.dumps(data).encode("utf-8")
data = gzip.compress(data)
resp = requests.post("http://localhost:8760/push_data/",data=data,headers={"Content-Encoding": "gzip", "Content-Type":"application/json;charset=utf-8"})
print(resp.json())
以上就是如何用Django處理gzip數(shù)據(jù)流的詳細(xì)內(nèi)容，更多關(guān)于Django處理gzip數(shù)據(jù)流的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
您可能感興趣的文章:- Django url 路由匹配過(guò)程詳解
- python基于爬蟲(chóng)+django，打造個(gè)性化API接口
- 詳解Django關(guān)于StreamingHttpResponse與FileResponse文件下載的最優(yōu)方法
- Django 實(shí)現(xiàn)圖片上傳和下載功能
- Django前后端分離csrf token獲取方式
- django中ImageField的使用詳解
- Django用內(nèi)置方法實(shí)現(xiàn)簡(jiǎn)單搜索功能的方法
- 用ldap作為django后端用戶(hù)登錄驗(yàn)證的實(shí)現(xiàn)
- 詳解Django自定義圖片和文件上傳路徑(upload_to)的2種方式
- Django數(shù)據(jù)統(tǒng)計(jì)功能count()的使用
- Django REST Framework 分頁(yè)(Pagination)詳解
