调试调研链路

rocketmq_util.py

@@ -130,7 +130,7 @@ if __name__ == '__main__':
                 'coolingWaterFlow': 639.2,
                 'time': time.time()
             }
-            RocketClient.send_sync(ALG_RESP_TOPIC,body=json.dumps(body))
+            RocketClient.send_sync(ALG_RESP_TOPIC,body=json.dumps(body, ensure_ascii=False))
             return ConsumeStatus.CONSUME_SUCCESS
         except Exception as e:
             print(e)