This commit is contained in:
Виктор Гладких 2019-10-04 10:15:07 +03:00
parent 6e9da70594
commit ca38f369f7

View File

@ -1,14 +0,0 @@
from pika import BlockingConnection, ConnectionParameters
def mess():
connection = BlockingConnection(ConnectionParameters('rabbitmq'))
channel = connection.channel()
channel.queue_declare(queue='rating')
channel.basic_publish(
exchange='',
routing_key='rating',
body='{news_id:127.0.0.1}'
)
connection.close()