Topik ini memberikan contoh cara menggunakan clickhouse-client untuk mengimpor data ke ApsaraDB for ClickHouse. Contoh ini menunjukkan pengimporan dataset On Time ke tabel terdistribusi ontime_local_distributed dalam database clickhouse_demo.
Prasyarat
Langkah-langkah berikut dari Panduan Memulai telah selesai:
- Catatan
Tambahkan alamat IP server tempat clickhouse-client diinstal ke daftar putih kluster ApsaraDB for ClickHouse.
clickhouse-client yang sesuai dengan versi kluster ApsaraDB for ClickHouse telah diinstal. Untuk informasi lebih lanjut, lihat clickhouse-client.
Prosedur
Klik Data On Time untuk mengunduh dataset On Time.
Ekstrak paket dataset On Time yang telah diunduh.
unzip ontime-data(1).zipHubungkan ke kluster ApsaraDB for ClickHouse dan impor data ke ApsaraDB for ClickHouse.
Jalankan perintah berikut di direktori tempat clickhouse-client diinstal:
./clickhouse-client --host=<host> --port=<port> --user=<user> --password=<password> --query="INSERT INTO <ClickHouse_table> FORMAT CSVWithNames" < ontime-data.csvTabel berikut menjelaskan parameter:
Parameter
Deskripsi
hostTitik akhir publik atau titik akhir virtual private cloud (VPC). Anda dapat melihat titik akhir publik atau VPC pada halaman Cluster Information.
Jika server tempat clickhouse-client diinstal ditempatkan di VPC yang sama dengan kluster ApsaraDB for ClickHouse, gunakan titik akhir VPC. Jika server dan kluster ditempatkan di VPC yang berbeda, gunakan titik akhir publik.
portNomor port TCP. Anda dapat melihat nomor port TCP pada halaman Cluster Information.
userAkun basis data. Anda dapat membuat akun basis data di konsol ApsaraDB for ClickHouse.
passwordKata sandi akun basis data.
ClickHouse_tableTabel di ApsaraDB for ClickHouse ke mana Anda ingin mengimpor data.
Contoh pernyataan berikut disediakan:
./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.csvKueri data untuk memeriksa apakah data berhasil diimpor.
SELECT OriginCityName, count(*) AS flights FROM ontime_local_distributed GROUP BY OriginCityName ORDER BY flights DESC LIMIT 10;Hasil kueri berikut dikembalikan:
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