-
Notifications
You must be signed in to change notification settings - Fork 0
/
homepowerproducer.py
27 lines (23 loc) · 1.07 KB
/
homepowerproducer.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
#!/usr/bin/env python
import pika
import random
import time
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='homepower', durable=True) #Name of queue
while True: #Messages will send every 2 seconds until the process is killed.
message = str(round(random.uniform(0,9001), 1))#Body accepts string
channel.basic_publish(exchange='',
routing_key='homepower', #Name of queue goes here
body=message,
properties=pika.BasicProperties(
delivery_mode = 2 # make message persistent, gets
#saved to disk or cache. This isn't foolproof, as
# there is a
#short time window in between receiving a message
#and saving it. Publisher confirms are a stronger
#guarantee.
))
print(" [x] Sent %r" % message)
time.sleep(2.0)
connection.close()