Utilisez l'outil clickhouse-client pour importer des données dans ApsaraDB for ClickHouse. Cet exemple importe le jeu de données On Time dans la table distribuée ontime_local_distributed de la base de données clickhouse_demo.
Prérequis
-
Avez effectué les étapes suivantes du guide de démarrage rapide :
-
Configurer une liste d'autorisation d'adresses IP
RemarqueAjoutez l'adresse IP du serveur sur lequel clickhouse-client est installé à la liste d'autorisation du cluster ApsaraDB for ClickHouse.
L'outil clickhouse-client doit être installé et sa version doit être compatible avec votre cluster ApsaraDB for ClickHouse. Pour les liens de téléchargement, consultez la page clickhouse-client.
Procédure
Cliquez sur On Time Data pour télécharger le jeu de données On Time.
-
Décompressez le jeu de données On Time téléchargé.
unzip ontime-data(1).zip -
Connectez-vous au cluster ApsaraDB for ClickHouse et importez les données dans ApsaraDB for ClickHouse.
Exécutez la commande suivante dans le répertoire d'installation de l'outil clickhouse-client.
./clickhouse-client --host=<host> --port=<port> --user=<user> --password=<password> --query="INSERT INTO <ClickHouse_table> FORMAT CSVWithNames" < ontime-data.csvLe tableau suivant décrit les paramètres de la commande.
Paramètre
Description
hostL'endpoint public ou l'endpoint VPC. Vous trouverez ces informations sur la page Cluster Information.
Utilisez l'endpoint VPC si votre serveur client et le cluster ApsaraDB for ClickHouse se trouvent dans le même VPC. Sinon, utilisez l'endpoint public.
portLe numéro de port TCP. Vous trouverez le numéro de port sur la page Cluster Information.
userLe compte de base de données créé dans la console ApsaraDB for ClickHouse.
passwordLe mot de passe du compte de base de données.
ClickHouse_tableLa table cible dans ApsaraDB for ClickHouse.
Exemple :
./clickhouse-client --host=cc-bp16qwvp7hy8i****.public.clickhouse.ads.aliyuncs.com --port=3306 --user=test --password=123456Aa --query="INSERT INTO clickhouse_demo.ontime_local_distributed FORMAT CSVWithNames" < ontime-data.csv -
Interrogez les données pour vérifier la réussite de l'importation.
SELECT OriginCityName, count(*) AS flights FROM ontime_local_distributed GROUP BY OriginCityName ORDER BY flights DESC LIMIT 10;Sortie attendue :
OriginCityName │ flights ──────────────────────│──────── Chicago, IL │ 24114 Atlanta, GA │ 22001 Dallas/Fort Worth, TX │ 17340 Los Angeles, CA │ 14494 Denver, CO │ 14170 New York, NY │ 14075 Washington, DC │ 11985 Houston, TX │ 11483 San Francisco, CA │ 11259 St. Louis, MO │ 10721