30 lines
1.6 KiB
Python
30 lines
1.6 KiB
Python
import pika
|
|
|
|
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', pika.PlainCredentials("user", "password")))
|
|
channel = connection.channel()
|
|
|
|
channel.queue_declare(queue='research_proposals')
|
|
|
|
proposals = [
|
|
{"acronym": "PRT1", "title": "Phantom Blood", "description": "Johnathen", "amount": "300000"},
|
|
{"acronym": "PRT2", "title": "Battle Tendency", "description": "Joseph", "amount": "400000"},
|
|
{"acronym": "PRT3", "title": "Stardust Crusaders", "description": "Jotaro", "amount": "250000"},
|
|
{"acronym": "PRT4", "title": "Diamond is Unbreakable", "description": "Josuke", "amount": "100000"},
|
|
{"acronym": "PRT5", "title": "Golden Wind", "description": "Giorno", "amount": "900000"},
|
|
{"acronym": "PRT6", "title": "Stone Ocean", "description": "Jolyne", "amount": "420000"},
|
|
{"acronym": "PRT7", "title": "Steel Ball Run", "description": "Johnny", "amount": "100000"},
|
|
{"acronym": "PRT8", "title": "Jojolion", "description": "Josuke", "amount": "900000"},
|
|
{"acronym": "PRT9", "title": "Jojolands", "description": "Jodio", "amount": "420000"}
|
|
]
|
|
|
|
for proposal in proposals:
|
|
result = channel.queue_declare(queue='', exclusive=True)
|
|
reply_to = result.method.queue
|
|
|
|
channel.basic_publish(exchange='',
|
|
routing_key='research_proposals',
|
|
properties=pika.BasicProperties(reply_to=reply_to),
|
|
body=f"{proposal['acronym']},{proposal['title']},{proposal['description']},{proposal['amount']}")
|
|
print(f"Proposal {proposal['acronym']} sent")
|
|
|
|
connection.close() |