Lindorm:Lindorm-cli を使用した LindormTSDB への接続と使用

テーブルの作成

1. 時系列データテーブルを作成します。

   CREATE TABLE sensor (
       device_id VARCHAR NOT NULL,
       region VARCHAR NOT NULL,
       time TIMESTAMP NOT NULL,
       temperature DOUBLE,
       humidity BIGINT,
       PRIMARY KEY(device_id, region, time)
   );

   説明

   • 時系列データテーブルを作成するときは、プライマリキー (PRIMARY KEY) を指定することをお勧めします。Basic Edition は PRIMARY KEY をサポートしていません。データソースの一意の識別子は、通常、IoT シナリオのデバイス ID、IoV (Internet of Vehicles) シナリオの一意の車両識別子、または監視シナリオのアプリケーション ID や ip:port など、PRIMARY KEY として指定されます。

   • タイムスタンプ列の名前は time である必要があります。この列は、データのタイムスタンプをミリ秒 (ms) 単位で示します。

2. sensor テーブルが作成されたかどうかを確認します。

   SHOW TABLES;

   次の結果が返されます:

   +-------------------+
   | Tables_In_default |
   +-------------------+
   | sensor            |
   +-------------------+

3. 時系列データテーブルのフィールド情報を表示します。

   DESCRIBE TABLE sensor;

   次の結果が返されます:

   +-------------+-----------+------------+------------+--------------+
   | columnName  | typeName  | columnKind | primaryKey | partitionTag |
   +-------------+-----------+------------+------------+--------------+
   | device_id   | VARCHAR   | TAG        | true       | true         |
   | region      | VARCHAR   | TAG        | true       | true         |
   | time        | TIMESTAMP | TIMESTAMP  | true       | false        |
   | temperature | DOUBLE    | FIELD      | false      | false        |
   | humidity    | BIGINT    | FIELD      | false      | false        |
   +-------------+-----------+------------+------------+--------------+

データの書き込み

• データポイントを 1 つずつ書き込みます。

  INSERT INTO sensor (device_id, region, time, temperature, humidity) VALUES('F07A1260','north-cn','2021-04-22 15:33:00',12.1,45);
  INSERT INTO sensor (device_id, region, time, temperature, humidity) VALUES('F07A1260','north-cn','2021-04-22 15:33:10',13.2,47);
  INSERT INTO sensor (device_id, region, time, temperature, humidity) VALUES('F07A1260','north-cn','2021-04-22 15:33:20',10.6,46);
  INSERT INTO sensor (device_id, region, time, temperature, humidity) VALUES('F07A1261','south-cn','2021-04-22 15:33:00',18.1,44);
  INSERT INTO sensor (device_id, region, time, temperature, humidity) VALUES('F07A1261','south-cn','2021-04-22 15:33:10',19.7,44);

• データをバッチで書き込みます。

  INSERT INTO sensor (device_id, region, time, temperature, humidity) 
  VALUES ('F07A1260','north-cn','2021-04-22 15:33:00',12.1,45),
         ('F07A1260','north-cn','2021-04-22 15:33:10',13.2,47),
         ('F07A1260','north-cn','2021-04-22 15:33:20',10.6,46),
         ('F07A1261','south-cn','2021-04-22 15:33:00',18.1,44),
         ('F07A1261','south-cn','2021-04-22 15:33:10',19.7,44);

データのクエリ

SELECT device_id,region,time,temperature,humidity FROM sensor WHERE device_id = 'F07A1260' AND time >= '2021-04-22 15:33:00' AND time <= '2021-04-22 15:33:20';

+-----------+----------+---------------------------+-------------+----------+
| device_id |  region  |           time            | temperature | humidity |
+-----------+----------+---------------------------+-------------+----------+
| F07A1260  | north-cn | 2021-04-22T15:33:00+08:00 | 12.1        | 45       |
| F07A1260  | north-cn | 2021-04-22T15:33:10+08:00 | 13.2        | 47       |
| F07A1260  | north-cn | 2021-04-22T15:33:20+08:00 | 10.6        | 46       |
+-----------+----------+---------------------------+-------------+----------+

SELECT device_id,region,time,max(temperature) AS max_temperature FROM sensor WHERE device_id = 'F07A1260' AND time >= '2021-04-22 15:33:00' AND time <= '2021-04-22 15:33:20' SAMPLE BY 20s;

+-----------+----------+---------------------------+-----------------+
| device_id |  region  |           time            | max_temperature |
+-----------+----------+---------------------------+-----------------+
| F07A1260  | north-cn | 2021-04-22T15:33:00+08:00 | 13.2            |
| F07A1260  | north-cn | 2021-04-22T15:33:20+08:00 | 10.6            |
+-----------+----------+---------------------------+-----------------+

SELECT region,max(temperature) AS max_temperature FROM sensor WHERE time >= '2021-04-22 15:33:00' AND time <= '2021-04-22 15:33:20' GROUP BY region;

+----------+-----------------+
|  region  | max_temperature |
+----------+-----------------+
| north-cn | 13.2            |
| south-cn | 19.7            |
+----------+-----------------+

データ挿入後にクエリ結果が空になるのはなぜですか？

データを書き込んだ後にクエリ結果が空になる場合は、DESCRIBE DATABASE <データベース名> 文を実行して、データベースに存続時間 (TTL) が設定されているかどうかを確認します。データの保持期間が TTL を超えると、データは自動的に削除され、クエリできなくなります。

Lindorm-cli を使用して時系列データをインポートおよびエクスポートできますか？

• 少量のデータの場合、Lindorm-cli を使用して CSV ファイルを迅速にインポートまたはエクスポートできます。この機能については、Lindorm テクニカルサポート (DingTalk グループ番号: s0s3eg3) にお問い合わせください。

• 大量のデータの場合、DataX を使用してデータをインポートすることをお勧めします。大規模なデータのエクスポートはサポートされていません。