system.asynchronous_insert_log

Table système contenant des informations sur les insertions asynchrones. Chaque entrée représente une requête d’insertion mise en tampon au sein d’une requête d’insertion asynchrone.

Interroger dans ClickHouse Cloud

Les données de cette table système sont stockées localement sur chaque nœud de ClickHouse Cloud. Pour obtenir une vue complète de l’ensemble des données, il faut donc utiliser la fonction clusterAllReplicas. Consultez cette page pour plus de détails.

​

Description

Contient des informations sur les insertions asynchrones. Chaque entrée représente une requête d’insertion mise en tampon dans une requête d’insertion asynchrone.

Pour activer la journalisation, configurez les paramètres dans la section asynchronous_insert_log.

La fréquence de vidage des données est définie par le paramètre flush_interval_milliseconds de la section des paramètres du serveur asynchronous_insert_log. Pour forcer le vidage, utilisez la requête SYSTEM FLUSH LOGS.

ClickHouse ne supprime pas automatiquement les données de la table. Consultez Introduction pour plus de détails.

​

Colonnes

• hostname (LowCardinality(String)) — Nom d’hôte du serveur qui exécute la requête.
• event_date (Date) — Date à laquelle l’async insert a eu lieu.
• event_time (DateTime) — Date et heure auxquelles l’async insert a fini de s’exécuter.
• event_time_microseconds (DateTime64(6)) — Date et heure auxquelles l’async insert a fini de s’exécuter, avec une précision à la microseconde.
• query (String) — Chaîne de la requête.
• database (LowCardinality(String)) — Nom de la base de données à laquelle appartient la table.
• table (LowCardinality(String)) — Nom de la table.
• format (LowCardinality(String)) — Nom du format.
• query_id (String) — ID de la requête initiale.
• bytes (UInt64) — Nombre d’octets insérés.
• rows (UInt64) — Nombre de lignes insérées.
• exception (String) — Message d’exception.
• status (Enum8(‘Ok’ = 0, ‘ParsingError’ = 1, ‘FlushError’ = 2)) — Statut de l’insertion. Valeurs : ‘Ok’ = 0 — Insertion réussie, ‘ParsingError’ = 1 — Exception lors de l’analyse des données, ‘FlushError’ = 2 — Exception lors du flush des données.
• data_kind (Enum8(‘Parsed’ = 0, ‘Preprocessed’ = 1)) — État des données. Valeurs : ‘Parsed’ et ‘Preprocessed’.
• flush_time (DateTime) — Date et heure auxquelles le flush a eu lieu.
• flush_time_microseconds (DateTime64(6)) — Date et heure auxquelles le flush a eu lieu, avec une précision à la microseconde.
• flush_query_id (String) — ID de la requête de flush.
• timeout_milliseconds (UInt64) — Timeout adaptatif calculé pour cette entrée.

​

Exemple

Query

SELECT * FROM system.asynchronous_insert_log LIMIT 1 \G;

Response

hostname:                clickhouse.eu-central1.internal
event_date:              2023-06-08
event_time:              2023-06-08 10:08:53
event_time_microseconds: 2023-06-08 10:08:53.199516
query:                   INSERT INTO public.data_guess (user_id, datasource_id, timestamp, path, type, num, str) FORMAT CSV
database:                public
table:                   data_guess
format:                  CSV
query_id:                b46cd4c4-0269-4d0b-99f5-d27668c6102e
bytes:                   133223
exception:
status:                  Ok
flush_time:              2023-06-08 10:08:55
flush_time_microseconds: 2023-06-08 10:08:55.139676
flush_query_id:          cd2c1e43-83f5-49dc-92e4-2fbc7f8d3716

​

Voir aussi

• system.query_log — Description de la table système query_log, qui contient des informations générales sur l’exécution des requêtes.
• system.asynchronous_inserts — Cette table contient des informations sur les inserts asynchrones en attente dans la file d’attente.