如何将Django处理gzip数据流转化为长尾关键词？

本文共计474个文字，预计阅读时间需要2分钟。

最近在工作中遇到一个需求，就是要开启一个接口来接收供应商推送的数据。项目采用Python的Django框架，我既不想也不想，就直接写了一堆哈希。以下是代码：

pythonclass XXDataPushView(APIView):

最近在工作中遇到一个需求，就是要开一个接口来接收供应商推送的数据。项目采用的python的django框架，我是想也没想，就直接一梭哈，写出了如下代码：

class XXDataPushView(APIView): """ 接收xx数据推送 """ # ... @white_list_required def post(self, request, **kwargs): req_data = request.data or {} # ...

但随后，发现每日数据并没有任何变化，质问供应商是否没有做推送，在忽悠我们。然后对方给的答复是，他们推送的是gzip压缩的数据流，接收端需要主动进行解压。此前从没有处理过这种压缩的数据，对方具体如何做的推送对我来说也是一个黑盒。

因此，我要求对方给一个推送的简单示例，没想到对方不讲武德，仍过来一段没法单独运行的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, FutureCallback<HttpResponse> 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, FutureCallback<HttpResponse> callback) { HttpUriRequest request = requestBuilder.build(); localhost:8760/push_data/",data=data,headers={"Content-Encoding": "gzip", "Content-Type":"application/json;charset=utf-8"}) print(resp.json())

以上就是如何用Django处理gzip数据流的详细内容，更多关于Django处理gzip数据流的资料请关注易盾网络其它相关文章！