18 lines
519 B
Python
18 lines
519 B
Python
from kombu import Connection, Exchange, Producer
|
|
|
|
# RabbitMQ ulanishi
|
|
rabbit_url = 'amqp://guest:guest@127.0.0.1:5672/'
|
|
connection = Connection(rabbit_url)
|
|
channel = connection.channel()
|
|
|
|
exchange = Exchange('notification', type='direct')
|
|
|
|
# Producer yaratish
|
|
producer = Producer(channel, exchange=exchange, routing_key="notification")
|
|
|
|
# Xabar yuborish
|
|
message = {'type': 'email', 'message': 'Hello, Workers!', "to": ["+998888112309", "+998943990509"]}
|
|
producer.publish(message)
|
|
|
|
print("Message sent to all workers!")
|