admin/video-render
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Ajusta rabbit

Browse Source
This commit is contained in:
admin
2025-08-05 04:39:03 +02:00
parent dd4f9fc51c
commit 0fd0cda460
1 changed files with 17 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
main.py
View File

@@ -37,6 +37,8 @@ def publish_to_queue(payload):
connection.close() connection.close()
def callback(ch, method, properties, body): def callback(ch, method, properties, body):
filename = url = video_id = None
try: try:
data = json.loads(body) data = json.loads(body)
filename = data.get("filename") filename = data.get("filename")
@@ -56,22 +58,28 @@ def callback(ch, method, properties, body):
"videoId": video_id, "videoId": video_id,
"error": False, "error": False,
} }
publish_to_queue(payload)
print(f"Mensagem publicada na fila '{RABBITMQ_UPLOAD_QUEUE}'.")
except Exception as e: except Exception as e:
payload = { payload = {
"videosProcessedQuantity": 0, "videosProcessedQuantity": 0,
"filename": filename if 'filename' in locals() else None, "filename": filename,
"processedFiles": [], "processedFiles": [],
"url": url if 'url' in locals() else None, "url": url,
"videoId": video_id if 'video_id' in locals() else None, "videoId": video_id,
"error": str(e), "error": str(e),
} }
print(f"Erro no processamento: {e}") print(f"Erro no processamento: {e}")
try: try:
publish_to_queue(payload) publish_to_queue(payload)
print(f"Mensagem publicada na fila '{RABBITMQ_UPLOAD_QUEUE}'.") print(f"Mensagem publicada na fila '{RABBITMQ_UPLOAD_QUEUE}'.")
except Exception as publish_err: except Exception as publish_err:
print(f"Erro ao publicar na fila '{RABBITMQ_UPLOAD_QUEUE}': {publish_err}") print(f"Erro ao publicar na fila '{RABBITMQ_UPLOAD_QUEUE}': {publish_err}")
ch.basic_ack(delivery_tag=method.delivery_tag) ch.basic_ack(delivery_tag=method.delivery_tag)