sprint/SprintLib/queue.py
Egor Matveev d2d427fd6e codestyle
2021-12-02 18:24:51 +03:00

17 lines
458 B
Python

import pika
from Sprint import settings
def send_testing(solution_id):
with pika.BlockingConnection(
pika.ConnectionParameters(host=settings.RABBIT_HOST, port=settings.RABBIT_PORT)
) as connection:
channel = connection.channel()
channel.queue_declare(queue="test")
channel.basic_publish(
exchange="",
routing_key="test",
body=bytes(str(solution_id), encoding="utf-8"),
)