fast-database-clients

A library to facilitate rapid deployment of a client to connect to various databases

fast-influxdb-client

from fast_influxdb_client import FastInfluxDBClient, InfluxMetric
import random
import time
from datetime import datetime, timezone

bucket = "metrics"
config_file = "config.toml"
# Create new client
client = FastInfluxDBClient.from_config_file(config_file=config_file)

# Generate some random data, and send to influxdb server
while 1:
    data = random.random()
    data2 = random.randint(0, 100)
    data3 = random.choice([True, False])

    metric = InfluxMetric(
        measurement="py_metric1",
        fields={"data1": data, "data2": data2, "data3": data3},
        time=datetime.now(timezone.utc),
    )

    client.write(metric)
    time.sleep(10)

Rich logging to influxdb is supported via the InfluxLoggingHandler class.

import logging
from fast_influxdb_client import FastInfluxDBClient

config_file = "config.toml"
client = FastInfluxDBClient.from_config_file(config_file=config_file)
client.create_bucket("logs")
client.default_bucket = "logs"

influx_handler = client.get_logging_handler()
influx_handler.setLevel(logging.INFO)

logger = logging.getLogger("fast_influxdb_client.fast_influxdb_client")
logger.addHandler(influx_handler)

logger.info("This log gets sent to InfluxDB")

Output as viewed in Grafana, showing log details