You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
74 lines
2.5 KiB
Python
74 lines
2.5 KiB
Python
#!/usr/bin/env python2
|
|
|
|
import RFM69_POCSAG
|
|
from RFM69_POCSAGregisters import *
|
|
import datetime
|
|
import time
|
|
from ConfigParser import SafeConfigParser
|
|
import pika
|
|
|
|
config = SafeConfigParser()
|
|
config.read('config.ini')
|
|
config.add_section('main')
|
|
config.set('main', 'amqpURI', 'amqp://user:pw@host:port')
|
|
|
|
with open('config.ini', 'w') as f:
|
|
config.write(f)
|
|
|
|
rfmModule = RFM69_POCSAG.RFM69_POCSAG(RF69_433MHZ, pocsagBaudRate=1200, isRFM69HW = True)
|
|
#rfmModule.shutdown()
|
|
|
|
print "Performing rcCalibration"
|
|
|
|
freqHz = 434790000
|
|
freqHz /= 61.03515625 # divide down by FSTEP to get FRF
|
|
freqHz = int(freqHz) + 35 # offset per chip (you may have to calibrate)
|
|
rfmModule.setFreqeuncy(freqHz)
|
|
|
|
rfmModule.rcCalibration()
|
|
rfmModule.setHighPower(True)
|
|
|
|
import uuid
|
|
def my_random_string(string_length=10):
|
|
"""Returns a random string of length string_length."""
|
|
random = str(uuid.uuid4())+str(uuid.uuid4())+str(uuid.uuid4())+str(uuid.uuid4())+str(uuid.uuid4())+str(uuid.uuid4())+str(uuid.uuid4())+str(uuid.uuid4()) # Convert UUID format to a Python string.
|
|
random = random.upper() # Make all characters uppercase.
|
|
random = random.replace("-","") # Remove the UUID '-'.
|
|
return random[0:string_length] # Return the random string.
|
|
|
|
def msgCallback(ch, method, properties, body):
|
|
print(" [x] Received %r" % body)
|
|
|
|
while True:
|
|
try:
|
|
connection = pika.BlockingConnection(pika.ConnectionParameters( config.get('main', 'amqpURI') ))
|
|
channel = connection.channel()
|
|
queue = channel.queue_declare(queue='input')
|
|
queue_ttl60 = channel.queue_declare(queue='input_ttl60')
|
|
channel.basic_consume(queue='input',
|
|
auto_ack=True,
|
|
on_message_callback=msgCallback)
|
|
channel.basic_consume(queue='input_ttl60',
|
|
auto_ack=True,
|
|
on_message_callback=msgCallback)
|
|
print(' [*] Waiting for messages. To exit press CTRL+C')
|
|
channel.start_consuming()
|
|
|
|
except Exception:
|
|
time.sleep(.5)
|
|
pass
|
|
|
|
|
|
from pocsag import encodeTXBatch
|
|
msgs = []
|
|
"""
|
|
msgs.append([False, "133722", 'Zeile 1\nZeile 2\nZeile 3\nZeile 4'])
|
|
msgs.append([False, "133742", '1234567890^12w3e4rt5zu<yxcvf1qwerdftgzhj123we4rwt5dezghqwertwe6456e5n6er6n45w6n456n45'])
|
|
msgs.append([True, "133782", "1234567890U-()"])
|
|
"""
|
|
msgs.append([False, "133702", my_random_string(80)])
|
|
|
|
data = encodeTXBatch(msgs)
|
|
rfmModule.sendBuffer(data)
|
|
time.sleep(2000)
|
|
#rfmModule.shutdown() |