Verileri ApsaraDB for ClickHouse içine aktarmak için clickhouse-client aracını kullanın. Bu örnekte, On Time veri kümesi clickhouse_demo veritabanındaki ontime_local_distributed dağıtılmış tablosuna aktarılır.
Ön koşullar
-
Hızlı Başlangıç kılavuzundaki aşağıdaki adımları tamamlamış olmanız gerekir:
-
IP adresi izin listesini yapılandırın
Notclickhouse-client kurulu olan sunucunun IP adresini ApsaraDB for ClickHouse kümesinin izin listesine ekleyin.
clickhouse-client aracının kurulu olduğundan ve sürümünün ApsaraDB for ClickHouse kümenizle uyumlu olduğundan emin olun. İndirme bağlantıları için bkz. clickhouse-client.
Yordam
On Time veri kümesini indirmek için On Time Data bağlantısına tıklayın.
-
İndirilen On Time veri kümesinin sıkıştırmasını açın.
unzip ontime-data(1).zip -
ApsaraDB for ClickHouse kümesine bağlanın ve verileri ApsaraDB for ClickHouse içine aktarın.
Aşağıdaki komutu clickhouse-client aracının kurulu olduğu dizinde çalıştırın.
./clickhouse-client --host=<host> --port=<port> --user=<user> --password=<password> --query="INSERT INTO <ClickHouse_table> FORMAT CSVWithNames" < ontime-data.csvAşağıdaki tabloda komuttaki parametreler açıklanmıştır.
Parametre
AçıklamahostGenel uç nokta veya VPC uç noktası. Bu bilgilere Cluster Information sayfasından ulaşabilirsiniz.
İstemci sunucunuz ve ApsaraDB for ClickHouse kümeniz aynı VPC içindeyse VPC uç noktasını kullanın. Aksi takdirde genel uç noktayı kullanın.
port
TCP bağlantı noktası numarası. Bağlantı noktası numarasını Cluster Information sayfasında bulabilirsiniz.user
ApsaraDB for ClickHouse konsolunda oluşturduğunuz veritabanı hesabı.password
Veritabanı hesabının parolası.ClickHouse_table
ApsaraDB for ClickHouse içindeki hedef tablo.Örnek:
./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 -
Aktarmanın başarılı olduğunu doğrulamak için verileri sorgulayın.
SELECT OriginCityName, count(*) AS flights FROM ontime_local_distributed GROUP BY OriginCityName ORDER BY flights DESC LIMIT 10;Beklenen çıktı:
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