Bulk insert for new data

timescaledb-v2.py

def WriteSQLToDB(timestamp: datetime, data_points: list) -> None:
    try:
        sqlEngine = create_engine(
            db_conn,
            pool_recycle=300,
            pool_pre_ping=True,
            connect_args={"connect_timeout": 20},
        )

        # Build a single SQL statement with multiple VALUES
        values_list = []
        for point in data_points:
            tag_name = point["tag_name"]
            tag_value = point["tag_value"]
            values_list.append(f"('{timestamp}', '{tag_name}', {tag_value})")

        sql = f"INSERT INTO sensors_data (time, tagname, tagvalue) VALUES {', '.join(values_list)}"

        with sqlEngine.connect() as connection:
            connection.execute(text(sql))
            connection.commit()
        print(f"-- DB: {len(values_list)} records inserted in bulk.")
    except Exception as e:
        print(f"** DB: Could not save to database. Error: {e}")
    finally:
        sqlEngine.dispose()