Cloud Composer 1 | Cloud Composer 2 | Cloud Composer 3
Halaman ini menunjukkan cara menggunakan Secret Manager untuk menyimpan koneksi dan secret Airflow dengan aman.
Mengonfigurasi Secret Manager untuk lingkungan Anda
Bagian ini menjelaskan cara mengonfigurasi Secret Manager agar Anda dapat menggunakan secret dengan lingkungan Cloud Composer.
Mengaktifkan Secret Manager API
Konsol
Aktifkan API Secret Manager.
gcloud
Aktifkan API Secret Manager:
gcloud services enable secretmanager.googleapis.com
Mengonfigurasi kontrol akses
Anda harus mengonfigurasi kontrol akses agar Airflow dapat mengakses secret yang disimpan di Secret Manager.
Untuk melakukannya, akun layanan yang mengakses secret harus memiliki peran dengan izin secretmanager.versions.access
. Misalnya,
peran Secret Manager Secret Accessor mencakup izin ini.
Anda dapat memberikan peran ini di tingkat Secret, Project, Folder, atau Org.
Gunakan salah satu opsi berikut:
(Direkomendasikan) Berikan peran ini ke akun layanan lingkungan Anda.
Ganti akun layanan yang digunakan Airflow untuk mengakses Secret Manager.
- Berikan peran ini ke akun layanan.
- Tetapkan parameter
gcp_key_path
daribackend_kwargs
opsi konfigurasi Airflow agar mengarah ke file JSON dengan kredensial akun layanan.
Mengaktifkan dan mengonfigurasi backend Secret Manager
Ganti opsi konfigurasi Airflow berikut:
Bagian Kunci Nilai secrets
backend
airflow.providers.google.cloud.secrets.secret_manager.CloudSecretManagerBackend
Tambahkan setelan opsional dengan mengganti opsi konfigurasi Airflow berikut:
Bagian Kunci Nilai secrets
backend_kwargs
Lihat deskripsi berikut. Nilai
backend_kwargs
adalah representasi JSON dari objekbackend_kwargs
dengan kolom berikut:connections_prefix
: awalan nama secret yang akan dibaca untuk mendapatkan Koneksi. Defaultnya adalahairflow-connections
.variables_prefix
: awalan nama secret yang akan dibaca untuk mendapatkan Variabel. Default-nya adalah:airflow-variables
.gcp_key_path
: jalur ke file JSON Kredensial Google Cloud (jika tidak diberikan, akun layanan default akan digunakan).gcp_keyfile_dict
: Kamus JSON Kredensial Google Cloud. Tidak dapat muncul bersama-sama dengangcp_key_path
.sep
: pemisah yang digunakan untuk menyambungkanconnections_prefix
danconn_id
. Defaultnya adalah-
.project_id
: Project ID Google Cloud tempat secret disimpan.
Misalnya, nilai
backend_kwargs
dapat berupa:{"project_id": "<project id>", "connections_prefix":"example-connections", "variables_prefix":"example-variables", "sep":"-"}
.
Menambahkan koneksi dan variabel di Secret Manager
Buat secret dengan mengikuti langkah-langkah yang diuraikan dalam Membuat secret dan versi.
Variabel
- Harus menggunakan format
[variables_prefix][sep][variable_name]
. - Nilai default untuk
[variables_prefix]
adalahairflow-variables
. - Pemisah default
[sep]
adalah-
.
Misalnya, jika nama variabel adalah example-var
, nama secret-nya
adalah airflow-variables-example-var
.
Nama koneksi
- Harus menggunakan format
[connection_prefix][sep][connection_name]
. - Nilai default untuk
[connection_prefix]
adalahairflow-connections
. - Pemisah default
[sep]
adalah-
.
Misalnya, jika nama koneksi adalah exampleConnection
, nama secret-nya adalah airflow-connections-exampleConnection
.
Nilai koneksi
Harus menggunakan representasi URI. Contoh,
postgresql://login:secret@examplehost:9000
.URI harus dienkode ke URL (dienkode persen). Misalnya, sandi yang memiliki simbol spasi di dalamnya harus dienkode URL sebagai berikut:
postgresql://login:secret%20password@examplehost:9000
.
Airflow memiliki metode praktis untuk membuat URI koneksi. Contoh cara mengenkode URL kompleks dengan tambahan JSON tersedia di dokumentasi Airflow.
Menggunakan Secret Manager dengan Cloud Composer
Saat mengambil variabel dan koneksi, Cloud Composer akan memeriksa Secret Manager terlebih dahulu. Jika variabel atau koneksi yang diminta tidak ditemukan, Cloud Composer akan memeriksa variabel lingkungan dan database Airflow.
Membaca variabel menggunakan template Jinja
Anda dapat menggunakan Secret Manager untuk membaca variabel dengan template Jinja untuk kolom operator dengan template (diselesaikan pada waktu eksekusi).
Untuk secret airflow-variables-secret_filename
:
file_name = '{{var.value.secret_filename}}'
Membaca variabel menggunakan operator dan callback kustom
Anda juga dapat menggunakan Secret Manager untuk membaca variabel dalam operator kustom atau metode callback dari operator. Membaca variabel dari dalam DAG dapat berdampak negatif pada performa, jadi gunakan template Jinja jika Anda ingin menggunakan variabel dalam DAG.
Misalnya, untuk secret airflow-variables-secret_filename
:
from airflow.models.variable import Variable
file_name = Variable.get('secret_filename')
Membaca koneksi
Kecuali jika Anda menulis operator kustom, Anda jarang perlu mengakses koneksi secara langsung. Sebagian besar hook mendapatkan nama koneksi sebagai parameter pembuatan instance, dan harus mengambil koneksi dari backend secret secara otomatis saat tugas dieksekusi.
Membaca koneksi secara langsung mungkin berguna saat menulis hook Anda sendiri.
Misalnya, untuk koneksi airflow-connections-exampleConnection
:
from airflow.hooks.base_hook import BaseHook
exampleConnection = BaseHook.get_connection('exampleConnection')
BaseHook.get_connection
menampilkan objek Connection
. Anda
dapat mendapatkan representasi string URI koneksi seperti ini:
exampleConnectionUri = BaseHook.get_connection('exampleConnection').get_uri()