OpenTSDB JSON Protocol

Similar to OpenTSDB line protocol, will be used as the STable name, timestamp is the timestamp to be used, value represents the metric collected, tags are the tag sets.

Please refer to for more details.

note
  • In JSON protocol, strings will be converted to NCHAR type and numeric values will be converted to double type.
  • The child table name is created automatically in a rule to guarantee its uniqueness. But you can configure smlChildTableName in taos.cfg to specify a tag value as the table names if the tag value is unique globally. For example, if a tag is called tname and you set smlChildTableName=tname in taos.cfg, when you insert st,tname=cpu1,t1=4 c1=3 1626006833639000000, the child table cpu1 will be automatically created. Note that if multiple rows have the same tname but different tag_set values, the tag_set of the first row is used to create the table and the others are ignored.
  • Java
  • Python
  • Go
  • Node.js
  • C#
  • C
  1. package com.taos.example;
  3. import com.taosdata.jdbc.SchemalessWriter;
  4. import com.taosdata.jdbc.enums.SchemalessProtocolType;
  5. import com.taosdata.jdbc.enums.SchemalessTimestampType;
  7. import java.sql.Connection;
  8. import java.sql.DriverManager;
  9. import java.sql.SQLException;
  10. import java.sql.Statement;
  12. public class JSONProtocolExample {
  13.     private static Connection getConnection() throws SQLException {
  14.         String jdbcUrl = "jdbc:TAOS://localhost:6030?user=root&password=taosdata";
  15.         return DriverManager.getConnection(jdbcUrl);
  16.     }
  18.     private static void createDatabase(Connection conn) throws SQLException {
  19.         try (Statement stmt = conn.createStatement()) {
  20.             stmt.execute("CREATE DATABASE IF NOT EXISTS test");
  21.             stmt.execute("USE test");
  22.         }
  23.     }
  25.     private static String getJSONData() {
  26.         return "[{\"metric\": \"meters.current\", \"timestamp\": 1648432611249, \"value\": 10.3, \"tags\": {\"location\": \"California.SanFrancisco\", \"groupid\": 2}}," +
  27.                 " {\"metric\": \"meters.voltage\", \"timestamp\": 1648432611249, \"value\": 219, \"tags\": {\"location\": \"California.LosAngeles\", \"groupid\": 1}}, " +
  28.                 "{\"metric\": \"meters.current\", \"timestamp\": 1648432611250, \"value\": 12.6, \"tags\": {\"location\": \"California.SanFrancisco\", \"groupid\": 2}}," +
  29.                 " {\"metric\": \"meters.voltage\", \"timestamp\": 1648432611250, \"value\": 221, \"tags\": {\"location\": \"California.LosAngeles\", \"groupid\": 1}}]";
  30.     }
  32.     public static void main(String[] args) throws SQLException {
  33.         try (Connection conn = getConnection()) {
  34.             createDatabase(conn);
  35.             SchemalessWriter writer = new SchemalessWriter(conn);
  36.             String jsonData = getJSONData();
  37.             writer.write(jsonData, SchemalessProtocolType.JSON, SchemalessTimestampType.NOT_CONFIGURED);
  38.         }
  39.     }
  40. }
  1. import json
  3. import taos
  4. from taos import SmlProtocol, SmlPrecision
  6. lines = [{"metric": "meters.current", "timestamp": 1648432611249, "value": 10.3, "tags": {"location": "California.SanFrancisco", "groupid": 2}},
  7.          {"metric": "meters.voltage", "timestamp": 1648432611249, "value": 219,
  8.           "tags": {"location": "California.LosAngeles", "groupid": 1}},
  9.          {"metric": "meters.current", "timestamp": 1648432611250, "value": 12.6,
  10.           "tags": {"location": "California.SanFrancisco", "groupid": 2}},
  11.          {"metric": "meters.voltage", "timestamp": 1648432611250, "value": 221, "tags": {"location": "California.LosAngeles", "groupid": 1}}]
  14. def get_connection():
  15.     return taos.connect()
  18. def create_database(conn):
  19.     conn.execute("CREATE DATABASE test")
  20.     conn.execute("USE test")
  23. def insert_lines(conn):
  24.     global lines
  25.     # note: the first parameter must be a list with only one element.
  26.     affected_rows = conn.schemaless_insert(
  28.     print(affected_rows)  # 4
  31. if __name__ == '__main__':
  32.     connection = get_connection()
  33.     try:
  34.         create_database(connection)
  35.         insert_lines(connection)
  36.     finally:
  37.         connection.close()

view source code

  1. const taos = require("@tdengine/client");
  3. const conn = taos.connect({
  4.   host: "localhost",
  5. });
  7. const cursor = conn.cursor();
  9. function createDatabase() {
  10.   cursor.execute("CREATE DATABASE test");
  11.   cursor.execute("USE test");
  12. }
  14. function insertData() {
  15.   const lines = [
  16.     {
  17.       metric: "meters.current",
  18.       timestamp: 1648432611249,
  19.       value: 10.3,
  20.       tags: { location: "California.SanFrancisco", groupid: 2 },
  21.     },
  22.     {
  23.       metric: "meters.voltage",
  24.       timestamp: 1648432611249,
  25.       value: 219,
  26.       tags: { location: "California.LosAngeles", groupid: 1 },
  27.     },
  28.     {
  29.       metric: "meters.current",
  30.       timestamp: 1648432611250,
  31.       value: 12.6,
  32.       tags: { location: "California.SanFrancisco", groupid: 2 },
  33.     },
  34.     {
  35.       metric: "meters.voltage",
  36.       timestamp: 1648432611250,
  37.       value: 221,
  38.       tags: { location: "California.LosAngeles", groupid: 1 },
  39.     },
  40.   ];
  42.   cursor.schemalessInsert(
  43.     [JSON.stringify(lines)],
  44.     taos.SCHEMALESS_PROTOCOL.TSDB_SML_JSON_PROTOCOL,
  45.     taos.SCHEMALESS_PRECISION.TSDB_SML_TIMESTAMP_NOT_CONFIGURED
  46.   );
  47. }
  49. try {
  50.   createDatabase();
  51.   insertData();
  52. } finally {
  53.   cursor.close(); 
  54.   conn.close();
  55. }
  1. using TDengineDriver;
  3. namespace TDengineExample
  4. {
  5.     internal class OptsJsonExample
  6.     {
  7.         static void Main()
  8.         {
  9.             try
  11.                 PrepareDatabase(conn);
  12.                 string[] lines = { "[{\"metric\": \"meters.current\", \"timestamp\": 1648432611249, \"value\": 10.3, \"tags\": {\"location\": \"California.SanFrancisco\", \"groupid\": 2}}," +
  13.                 " {\"metric\": \"meters.voltage\", \"timestamp\": 1648432611249, \"value\": 219, \"tags\": {\"location\": \"California.LosAngeles\", \"groupid\": 1}}, " +
  14.                 "{\"metric\": \"meters.current\", \"timestamp\": 1648432611250, \"value\": 12.6, \"tags\": {\"location\": \"California.SanFrancisco\", \"groupid\": 2}}," +
  15.                 " {\"metric\": \"meters.voltage\", \"timestamp\": 1648432611250, \"value\": 221, \"tags\": {\"location\": \"California.LosAngeles\", \"groupid\": 1}}]"
  16.             };
  18.                 IntPtr res = TDengine.SchemalessInsert(conn, lines, 1, (int)TDengineSchemalessProtocol.TSDB_SML_JSON_PROTOCOL, (int)TDengineSchemalessPrecision.TSDB_SML_TIMESTAMP_NOT_CONFIGURED);
  19.                 if (TDengine.ErrorNo(res) != 0)
  20.                 {
  21.                     throw new Exception("SchemalessInsert failed since " + TDengine.Error(res));
  22.                 }
  23.                 else
  24.                 {
  25.                     int affectedRows = TDengine.AffectRows(res);
  26.                     Console.WriteLine($"SchemalessInsert success, affected {affectedRows} rows");
  27.                 }
  28.                 TDengine.FreeResult(res);
  29.             }
  30.             finally
  31.             {
  32.                 TDengine.Close(conn);
  33.             }
  34.         }
  35.         static IntPtr GetConnection()
  36.         {
  37.             string host = "localhost";
  38.             short port = 6030;
  39.             string username = "root";
  40.             string password = "taosdata";
  41.             string dbname = "";
  42.             var conn = TDengine.Connect(host, username, password, dbname, port);
  43.             if (conn == IntPtr.Zero)
  44.             {
  45.                 throw new Exception("Connect to TDengine failed");
  46.             }
  47.             else
  48.             {
  49.                 Console.WriteLine("Connect to TDengine success");
  50.             }
  51.             return conn;
  52.         }
  54.         static void PrepareDatabase(IntPtr conn)
  55.         {
  56.             IntPtr res = TDengine.Query(conn, "CREATE DATABASE test");
  57.             if (TDengine.ErrorNo(res) != 0)
  58.             {
  59.                 throw new Exception("failed to create database, reason: " + TDengine.Error(res));
  60.             }
  61.             res = TDengine.Query(conn, "USE test");
  62.             if (TDengine.ErrorNo(res) != 0)
  63.             {
  64.                 throw new Exception("failed to change database, reason: " + TDengine.Error(res));
  65.             }
  66.         }
  67.     }
  68. }

view source code

  1. taos> use test;
  2. Database changed.
  4. taos> show stables;
  5.               name              |
  6. =================================
  7.  meters.current                 |
  8.  meters.voltage                 |
  9. Query OK, 2 row(s) in set (0.001954s)
  11. taos> select * from `meters.current`;
  12.            _ts            |           _value           |          groupid          |            location            |
  13. ===================================================================================================================
  14.  2022-03-28 09:56:51.249 |              10.300000000 |               2.000000000 | California.SanFrancisco               |
  15.  2022-03-28 09:56:51.250 |              12.600000000 |               2.000000000 | California.SanFrancisco               |
  16. Query OK, 2 row(s) in set (0.004076s)

If you want query the data of “tags”: {“location”: “California.LosAngeles”, “groupid”: 1}，here is the query SQL: