birbnetes/output-service-tsdb
birbnetes/output-service-tsdb
4
0
Fork 0
Code Issues Releases Activity

most lesz a jo
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Pünkösd Marcell 2020-05-29 18:35:45 +02:00
parent 79151695f8
commit 6606ec0699
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/app.py
View File

@ -40,8 +40,9 @@ async def on_message(message: IncomingMessage):
'fields': {'probability': msg_json['probability']} 'fields': {'probability': msg_json['probability']}
} }
async with InfluxDBClient(username=config.INFLUXDB_USERNAME, password=config.INFLUXDB_PASSWORD, async with InfluxDBClient(username=config.INFLUXDB_USERNAME, password=config.INFLUXDB_PASSWORD,
host=config.INFLUXDB_HOST, port=config.INFLUXDB_PORT, ssl=False) as client: host=config.INFLUXDB_HOST, port=config.INFLUXDB_PORT, ssl=False,
await client.create_database(db=config.INFLUXDB_DB) database=config.INFLUXDB_DB) as client:
await client.create_database(config.INFLUXDB_DB)
await client.write(point) await client.write(point)