Lindorm:Se connecter et utiliser le moteur de séries temporelles à l'aide de Lindorm-cli

Créer une table

1. Créez une table de séries temporelles.

   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)
   );

   Remarque

   • Lors de la création d'une table de séries temporelles, spécifiez une clé primaire (PRIMARY KEY). L'édition Basic ne prend pas en charge PRIMARY KEY. En règle générale, utilisez un identifiant unique de votre source de données comme PRIMARY KEY. Parmi les exemples figurent l'ID de périphérique dans les scénarios IoT, l'ID de véhicule dans les scénarios IoV, l'ID d'application dans les scénarios de surveillance, ou ip:port.

   • Le nom de colonne pour l'horodatage doit être time, qui représente l'horodatage des données en millisecondes (ms).

2. Vérifiez que la table sensor a bien été créée.

   SHOW TABLES;

   Le résultat de la requête est le suivant :

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

3. Affichez les colonnes de la table de séries temporelles.

   DESCRIBE TABLE sensor;

   Le résultat de la requête est le suivant :

   +-------------+-----------+------------+------------+--------------+
   | 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        |
   +-------------+-----------+------------+------------+--------------+

Écrire des données

• Écrivez les données ligne par ligne.

  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);

• Écrivez les données par lots.

  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);

Interroger des données

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            |
+----------+-----------------+

Pourquoi le résultat de la requête est-il vide après une insertion de données réussie ?

Si une requête ne renvoie aucune donnée après une écriture réussie, vérifiez si la base de données possède un paramètre TTL (Time-To-Live) en exécutant DESCRIBE DATABASE <nom de la base de données>. Les données antérieures au TTL sont automatiquement supprimées et ne peuvent pas être interrogées.

Lindorm-cli peut-il importer ou exporter des données de séries temporelles ?

• Pour de petits volumes de données, vous pouvez utiliser Lindorm-cli pour importer ou exporter rapidement des fichiers CSV. Contactez le support technique Lindorm (ID DingTalk : s0s3eg3) si nécessaire.

• Pour de grands volumes de données, importez les données à l'aide de DataX. L'exportation de données à grande échelle n'est pas prise en charge.