Merge branch 'master' of http://47.101.198.30:3000/xiaopzhang/celery

celery_app2.py

@@ -0,0 +1,9 @@
+from celery import Celery
+celery_app2 = Celery(
+"tasks",
+broker="redis://:Pheecian1@47.101.198.30:6379/2",
+backend="redis://:Pheecian1@47.101.198.30:6379/3",
+)
+celery_app2.conf.update(redis_socket_timeout=30)
+celery_app2.conf.update(redis_retry_on_timeout=True)
+celery_app2.conf.update(task_track_started=True)

tasks2.py

@@ -0,0 +1,15 @@
+import time
+from celery_app2 import celery_app2
+from pymongo import MongoClient
+uri="mongodb://owner:Pheecian1@47.101.198.30:27017/baojia"
+mongoclient=MongoClient(uri)
+db = mongoclient['baojia']
+dbcollection=db['Dwgc']
+from redis.exceptions import TimeoutError
+@celery_app2.task(autoretry_for=(TimeoutError,))
+def process_data(data:dict)-> dict:
+    print(data['name'])
+    print(data['detail'])##dwgcbh
+    result = dbcollection.update_one({'biao_id': data['name'], 'Dwgcbh': data['detail']}, {'$set': {'status': '开始'}})
+    print(result)
+    return {"result": []}