Membaca dari database PostgreSQL

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

Sebelum memulai

  • Buat instance Cloud Data Fusion.
  • Aktifkan database PostgreSQL Anda untuk menerima koneksi dari Cloud Data Fusion. Untuk melakukannya secara aman, sebaiknya Anda menggunakan instance Cloud Data Fusion pribadi.

Peran yang diperlukan

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

  • Dataproc Worker (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: Klien Cloud SQL (roles/cloudsql.client) di project yang berisi instance Cloud SQL

Untuk mengetahui informasi selengkapnya tentang cara memberikan peran, lihat Mengelola akses ke project, folder, dan organisasi.

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

Membuka instance di Cloud Data Fusion

  1. Di konsol Google Cloud , buka halaman Cloud Data Fusion.

  2. Untuk membuka instance di Cloud Data Fusion Studio, klik Instance, lalu klik View instance.

    Buka Instance

Menyimpan sandi PostgreSQL Anda sebagai kunci aman

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

  1. Di UI Cloud Data Fusion, klik Admin sistem > Konfigurasi.

  2. Klik Make HTTP Calls.

    Konfigurasi.

  3. Di menu dropdown, pilih PUT.

  4. Di kolom jalur, masukkan namespaces/default/securekeys/pg_password.

  5. Di kolom Body, masukkan {"data":"POSTGRESQL_PASSWORD"}. Ganti POSTGRESQL_PASSWORD dengan sandi PostgreSQL Anda.

  6. Klik Kirim.

    Sandi.

Kolom Respons akan memberi tahu Anda jika terjadi error.

Menghubungkan ke Cloud SQL untuk PostgreSQL

  1. Di UI Cloud Data Fusion, klik menu dan buka halaman Wrangler.

  2. Klik Tambahkan koneksi.

  3. Pilih Database sebagai jenis sumber yang akan dihubungkan.

    Tambahkan koneksi.

  4. Di bagian Google Cloud SQL untuk PostgreSQL, klik Upload.

    Pilih sumber.

  5. 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 Anda menguploadnya.

  6. Klik Berikutnya.

  7. Masukkan nama, nama kelas, dan versi driver di kolom.

  8. Klik Selesai.

  9. Di jendela Tambahkan koneksi yang terbuka, klik Google Cloud SQL untuk PostgreSQL. Nama JAR Anda akan muncul di bagian Google Cloud SQL untuk PostgreSQL.

    JAR diupload.

  10. Isi kolom koneksi yang wajib diisi. Di kolom Password, pilih kunci aman yang Anda simpan sebelumnya. Hal ini memastikan bahwa sandi Anda diambil menggunakan Cloud KMS.

    Pilih sandi.

  11. Di kolom Connection string, 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 Database di halaman detail instance.
    • INSTANCE_CONNECTION_NAME: nama koneksi instance Cloud SQL seperti yang ditampilkan di tab Ringkasan pada halaman detail instance.
    Nama koneksi instance.

    Contoh: 

    jdbc:postgresql://google/postgres?cloudSqlInstance=dis-demo:us-central1:pgsql-1&socketFactory=com.google.cloud.sql.postgres.SocketFactory&useSSL=false

  12. Aktifkan Cloud SQL Admin API.

  13. Klik Uji koneksi untuk memastikan koneksi dapat dibuat dengan database.

  14. Klik Tambahkan koneksi.

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