aidlab/AiDA_Python
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Revert "design design batch"

Browse Source 
This reverts commit e6f0ee7f
This commit is contained in:
zhouchengrong
2024-12-11 13:51:22 +08:00
parent 731f07d252
commit 84fe2663f4
16 changed files with 24 additions and 279 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
app/service/design_batch/utils/MQ.py
View File

@@ -2,12 +2,9 @@ import json
import pika
from app.core.config import RABBITMQ_PARAMS
def publish_status(task_id, progress, result):
connection = pika.BlockingConnection(pika.ConnectionParameters(**RABBITMQ_PARAMS))
# connection = pika.BlockingConnection(pika.ConnectionParameters('10.1.2.190'))
connection = pika.BlockingConnection(pika.ConnectionParameters('10.1.2.213'))
channel = connection.channel()
channel.queue_declare(queue='DesignBatch', durable=True)
message = {'task_id': task_id, 'progress': progress, "result": result}
@@ -18,7 +15,3 @@ def publish_status(task_id, progress, result):
delivery_mode=2,
))
connection.close()
if __name__ == '__main__':
publish_status("1", "1", "1")