9 lines
261 B
Python
9 lines
261 B
Python
import pika
|
|
|
|
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials("user", "password")))
|
|
channel = connection.channel()
|
|
|
|
def log(data):
|
|
channel.basic_publish(exchange='', routing_key='log', body=data)
|
|
|