Skip to content
Snippets Groups Projects
Verified Commit 0082b3ea authored by Martin Weise's avatar Martin Weise
Browse files

Fixed the docs for PIKA

parent 661643c3
No related branches found
No related tags found
3 merge requests!231CI: Remove build for log-service,!228Better error message handling in the frontend,!223Release of version 1.4.0
......@@ -559,11 +559,15 @@ A user wants to import live data from e.g. sensor measurements fast and without
import pika
import json
connection = pika.BlockingConnection()
credentials = pika.credentials.PlainCredentials('foo', 'bar')
# credentials = pika.credentials.PlainCredentials('', 'ACCESS_TOKEN')
parameters = pika.ConnectionParameters('localhost', 5672, '/', credentials)
connection = pika.BlockingConnection(parameters)
channel = connection.channel()
channel.basic_publish(exchange='dbrepo',
routing_key='dbrepo.test_fiyg.dabube_water_levels',
body=json.dumps({"data":{"column1":"value1","column2":"value2"}}))
print(" [x] Sent tuple!")
connection.close()
```
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment