Lindorm:Lindorm-cli による時系列エンジンへの接続と使用

テーブルの作成

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 をサポートしていません。通常、データソースからの一意の識別子を PRIMARY KEY として使用します。例としては、IoT シナリオにおけるデバイス ID、IoV (Internet of Vehicles) シナリオにおける車両 ID、監視シナリオにおけるアプリケーション ID、または ip:port などが挙げられます。

   • タイムスタンプの列名は 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 <database name> を実行して、データベースに Time-to-Live (TTL) 設定があるかどうかを確認してください。TTL より古いデータは自動的に削除され、照会できません。

Lindorm-cli は時系列データをインポートまたはエクスポートできますか。

• データ量が少ない場合は、Lindorm-cli を使用して CSV ファイルを迅速にインポートまたはエクスポートできます。必要に応じて、Lindorm テクニカルサポート (DingTalk ID: s0s3eg3) にお問い合わせください。

• データ量が多い場合は、DataX を使用してデータをインポートしてください。大規模なデータのエクスポートはサポートされていません。