Membaca dari database PostgreSQL

Halaman ini menjelaskan cara membaca data dari database PostgreSQL dalam instance Cloud Data Fusion.

Sebelum memulai

Membuat instance Cloud Data Fusion.
Aktifkan database PostgreSQL Anda untuk menerima koneksi dari Cloud Data Fusion. Untuk melakukannya dengan aman, sebaiknya gunakan instance Cloud Data Fusion pribadi.

Peran yang diperlukan

Untuk mendapatkan izin yang diperlukan untuk terhubung ke database PostgreSQL, minta administrator untuk memberi Anda peran IAM berikut:

Pekerja Dataproc (roles/dataproc.worker) di akun layanan Dataproc dalam project yang berisi cluster
Cloud Data Fusion Runner (roles/datafusion.runner) di akun layanan Dataproc dalam project yang berisi cluster
Untuk menggunakan Cloud SQL tanpa Proxy Auth Cloud SQL: Cloud SQL Client (roles/cloudsql.client) pada project yang berisi instance Cloud SQL

Untuk mengetahui informasi selengkapnya tentang pemberian peran, lihat Mengelola akses.

Anda mungkin juga bisa mendapatkan izin yang diperlukan melalui peran khusus atau peran bawaan lainnya.

Membuka instance Anda di Cloud Data Fusion

Di konsol Google Cloud, buka halaman Cloud Data Fusion.
Untuk membuka instance di antarmuka web Cloud Data Fusion, klik Instance, lalu klik View instance.

Buka Instance

Simpan sandi PostgreSQL Anda sebagai kunci yang aman

Masukkan sandi PostgreSQL sebagai kunci aman untuk dienkripsi di instance Cloud Data Fusion Anda. Untuk mengetahui informasi lebih lanjut tentang kunci, lihat Cloud KMS.

Di UI Cloud Data Fusion, klik System admin > Configuration.
Klik Lakukan Panggilan HTTP.
Di menu dropdown, pilih PUT.
Di kolom jalur, masukkan namespaces/default/securekeys/pg_password.
Di kolom Body, masukkan {"data":"POSTGRESQL_PASSWORD"}. Ganti POSTGRESQL_PASSWORD dengan sandi PostgreSQL Anda.
Klik Kirim.

Kolom Response akan memberi tahu Anda jika ada error.

Terhubung ke Cloud SQL untuk PostgreSQL

Di UI Cloud Data Fusion, klik menu , lalu buka halaman Wrangler.
Klik Tambahkan koneksi.
Pilih Database sebagai jenis sumber yang akan dihubungkan.
Di bagian Google Cloud SQL untuk PostgreSQL, klik Upload.
Upload file JAR yang berisi driver PostgreSQL Anda. File JAR Anda harus mengikuti format NAME-VERSION.jar. Jika file JAR Anda tidak mengikuti format ini, ganti namanya sebelum mengupload.
Klik Next.
Masukkan nama driver, nama class, dan versi dalam kolom.
Klik Selesai.
Di jendela Add connection yang terbuka, klik Google Cloud SQL untuk PostgreSQL. Nama JAR Anda akan muncul di bagian Google Cloud SQL untuk PostgreSQL.
Isi kolom koneksi yang wajib diisi. Di kolom Password, pilih kunci aman yang Anda simpan sebelumnya. Tindakan ini memastikan bahwa sandi Anda diambil menggunakan Cloud KMS.
Di kolom String koneksi, masukkan string koneksi Anda sebagai:
```
jdbc:postgresql://google/DATABASE_NAME?cloudSqlInstance=INSTANCE_CONNECTION_NAME&socketFactory=com.google.cloud.sql.postgres.SocketFactory&useSSL=false
```
Ganti kode berikut:
- DATABASE_NAME: nama database Cloud SQL seperti yang tercantum di tab Databases di halaman detail instance.
- INSTANCE_CONNECTION_NAME: nama koneksi instance Cloud SQL seperti yang ditampilkan di tab Ringkasan di halaman detail instance.
Contoh:
```
jdbc:postgresql://google/postgres?cloudSqlInstance=dis-demo:us-central1:pgsql-1&socketFactory=com.google.cloud.sql.postgres.SocketFactory&useSSL=false
```
Aktifkan Cloud SQL Admin API.
Klik Test connection untuk memastikan bahwa koneksi dapat dibuat dengan database.
Klik Tambahkan koneksi.

Setelah database PostgreSQL terhubung, Anda dapat menerapkan transformasi ke data (di Wrangler), membuat pipeline, dan menulis output ke sink (di Studio).