telnet_line_protocol_example.py

import taos
from taos import SmlProtocol, SmlPrecision

# format: <metric> <timestamp> <value> <tagk_1>=<tagv_1>[ <tagk_n>=<tagv_n>]
lines = ["meters.current 1648432611249 10.3 location=Beijing.Chaoyang groupid=2",
         "meters.current 1648432611250 12.6 location=Beijing.Chaoyang groupid=2",
         "meters.current 1648432611249 10.8 location=Beijing.Haidian groupid=3",
         "meters.current 1648432611250 11.3 location=Beijing.Haidian groupid=3",
         "meters.voltage 1648432611249 219 location=Beijing.Chaoyang groupid=2",
         "meters.voltage 1648432611250 218 location=Beijing.Chaoyang groupid=2",
         "meters.voltage 1648432611249 221 location=Beijing.Haidian groupid=3",
         "meters.voltage 1648432611250 217 location=Beijing.Haidian groupid=3",
         ]


# create connection use firstEp in taos.cfg.
def get_connection():
    return taos.connect()


def create_database(conn):
    conn.execute("create database test")
    conn.execute("use test")


def insert_lines(conn):
    affected_rows = conn.schemaless_insert(lines, SmlProtocol.TELNET_PROTOCOL, SmlPrecision.NOT_CONFIGURED)
    print(affected_rows)  # 8


if __name__ == '__main__':
    connection = get_connection()
    try:
        create_database(connection)
        insert_lines(connection)
    finally:
        connection.close()