Bulk insert for InfluxDB 3

influxdb.py

def WriteInfluxDB(timestamp: datetime, points_data: list) -> None:
    try:
        # Create a list of Point objects
        points = []

        for point_data in points_data:
            tag_name = point_data["tag_name"]
            tag_value = point_data["tag_value"]

            point = (
                Point("homedb")
                .tag("sensor", tag_name)
                .field("value", tag_value)
                .time(timestamp, WritePrecision.NS)
            )
            points.append(point)

        # Write all points in a single batch operation
        client_influx.write(points)
        print(f"-- InfluxDB: {len(points)} records inserted.")
    except Exception as e:
        print(f"** InfluxDB: Could not save to database. Error: {e}")