/
FlysAt
/
DataFoundry
Обзор
Документация
Войти
/
FlysAt
/
DataFoundry
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
backend/src/api/queue/dataset_validation.py
33 строки
1 KB
AlexanderShmygol
add version datasets
03 май 2026, 16:21
03 май 2026, 16:21
81aab08
Код
Авторство
О чём код?
import json import pika from src.core.config import rabbitmq_settings class DatasetValidationQueue: def publish(self, part_id: int) -> None: connection = pika.BlockingConnection( pika.ConnectionParameters( host=rabbitmq_settings.RABBITMQ_HOST, port=rabbitmq_settings.RABBITMQ_PORT, credentials=pika.PlainCredentials( rabbitmq_settings.RABBITMQ_USER, rabbitmq_settings.RABBITMQ_PASSWORD, ), ) ) try: channel = connection.channel() channel.queue_declare( queue=rabbitmq_settings.RABBITMQ_DATASET_VALIDATION_QUEUE, durable=True, ) channel.basic_publish( exchange="", routing_key=rabbitmq_settings.RABBITMQ_DATASET_VALIDATION_QUEUE, body=json.dumps({"part_id": part_id}), properties=pika.BasicProperties(delivery_mode=2), ) finally: connection.close()