From 02c91a4afceca47e22ffaef219ecaff1004f179c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 13 三月 2024 11:05:54 +0800
Subject: [PATCH] 更改序列化传输方式
---
huaxin_client/l2_data_manager.py | 3 ++-
1 files changed, 2 insertions(+), 1 deletions(-)
diff --git a/huaxin_client/l2_data_manager.py b/huaxin_client/l2_data_manager.py
index d23c3d8..9a34109 100644
--- a/huaxin_client/l2_data_manager.py
+++ b/huaxin_client/l2_data_manager.py
@@ -1,6 +1,7 @@
# -*- coding: utf-8 -*-
import json
import logging
+import marshal
import multiprocessing
import queue
import threading
@@ -160,7 +161,7 @@
self.upload_l2_data_task_dict.pop(code)
def __upload_l2_data(self, code, _queue, datas):
- _queue.put_nowait((code, datas, time.time()))
+ _queue.put_nowait(marshal.dumps([code, datas, time.time()]))
# 澶勭悊璁㈠崟鏁版嵁骞朵笂浼�
def __run_upload_order_task(self, code):
--
Gitblit v1.8.0