Menjalankan tugas Cloud Run yang memproses data peristiwa yang disimpan di Cloud Storage

---

Anda dapat menggunakan Workflows untuk menjalankan tugas Cloud Run sebagai bagian dari alur kerja yang melakukan pemrosesan data yang lebih kompleks atau yang mengorkestrasi sistem tugas yang ada.

Tutorial ini menunjukkan cara menggunakan Workflows untuk menjalankan tugas Cloud Run yang memproses data peristiwa yang disimpan di bucket Cloud Storage. Dengan menyimpan payload peristiwa di bucket Cloud Storage, Anda dapat mengenkripsi data menggunakan kunci enkripsi yang dikelola pelanggan yang tidak mungkin dilakukan jika Anda meneruskan data peristiwa sebagai variabel lingkungan ke tugas Cloud Run.

Diagram berikut memberikan ringkasan umum:

Tujuan

Dalam tutorial ini, Anda akan:

1. Buat tugas Cloud Run yang memproses data peristiwa yang disimpan di bucket Cloud Storage.
2. Deploy alur kerja yang melakukan hal berikut:
   1. Menerima kejadian sebagai argumen.
   2. Menulis data payload peristiwa ke bucket Cloud Storage.
   3. Menggunakan konektor Cloud Run Admin API untuk menjalankan tugas Cloud Run.
3. Membuat topik Pub/Sub sehingga Anda dapat memublikasikan pesan ke topik tersebut. Tutorial ini menggunakan peristiwa Pub/Sub sebagai contoh cara merutekan peristiwa menggunakan Workflows, yang menyimpan peristiwa ke Cloud Storage sehingga tugas Cloud Run dapat memproses data peristiwa tersebut.
4. Buat pemicu Eventarc yang menjalankan alur kerja saat pesan ditulis ke topik Pub/Sub.
5. Picu alur kerja dengan menulis pesan ke topik Pub/Sub.

Biaya

Dalam dokumen ini, Anda menggunakan komponen Google Cloud yang dapat ditagih berikut:

• Cloud Build
• Cloud Run
• Cloud Storage
• Eventarc
• Workflows

Untuk membuat perkiraan biaya berdasarkan proyeksi penggunaan Anda, gunakan kalkulator harga. Pengguna baru Google Cloud mungkin memenuhi syarat untuk mendapatkan uji coba gratis.

Sebelum memulai

Batasan keamanan yang ditentukan oleh organisasi mungkin mencegah Anda menyelesaikan langkah-langkah berikut. Untuk mengetahui informasi pemecahan masalah, lihat Mengembangkan aplikasi di lingkungan Google Cloud yang terbatas.

Sebelum memulai tutorial ini, Anda harus mengaktifkan API tertentu dan membuat akun layanan yang dikelola pengguna. Anda harus memberikan peran dan izin yang diperlukan kepada akun layanan agar dapat merutekan peristiwa menggunakan pemicu Eventarc dan menjalankan alur kerja.

Konsol

1. Login ke akun Google Cloud Anda. Jika Anda baru menggunakan Google Cloud, buat akun untuk mengevaluasi performa produk kami dalam skenario dunia nyata. Pelanggan baru juga mendapatkan kredit gratis senilai $300 untuk menjalankan, menguji, dan men-deploy workload.

2. Di konsol Google Cloud, pada halaman pemilih project, pilih atau buat project Google Cloud.

   Catatan: Jika tidak berencana untuk menyimpan resource yang Anda buat dalam prosedur ini, buatlah project, bukan memilih project yang ada. Setelah menyelesaikan langkah ini, Anda dapat menghapus project, yang menghapus semua resource yang terkait dengan project ini.

   Buka pemilih project

3. Pastikan penagihan telah diaktifkan untuk project Google Cloud Anda.

4. Enable the Cloud Build, Cloud Run, Cloud Storage, Eventarc, and Workflows APIs.

   Enable the APIs

5. Buat akun layanan:

   1. Di konsol Google Cloud, buka halaman Buat akun layanan.

      Buka Create service account
   2. Pilih project Anda.

   3. Di kolom Nama akun layanan, masukkan nama. Konsol Google Cloud akan mengisi kolom ID akun layanan berdasarkan nama ini.

      Di kolom Deskripsi akun layanan, masukkan sebuah deskripsi. Sebagai contoh, Service account for quickstart.

   4. Klik Buat dan lanjutkan.

   5. Berikan peran berikut ke akun layanan: Cloud Run Admin, Eventarc Event Receiver, Logs Writer, Storage Object Creator, Workflows Invoker.

      Untuk memberikan peran, temukan daftar Pilih peran, lalu pilih peran.

      Untuk memberikan peran tambahan, klik Tambahkan peran lain, lalu tambahkan setiap peran tambahan.

      Catatan: Kolom Peran memengaruhi resource mana yang dapat diakses oleh akun layanan di project Anda. Anda dapat mencabut peran ini atau memberikan peran tambahan di lain waktu. Dalam lingkungan produksi, jangan berikan peran Owner, Editor, atau Viewer. Sebagai gantinya, berikan peran standar atau peran khusus yang memenuhi kebutuhan Anda.
   6. Klik Lanjutkan.

   7. Klik Selesai untuk menyelesaikan pembuatan akun layanan.

6. Di konsol Google Cloud, pada halaman pemilih project, pilih atau buat project Google Cloud.

   Catatan: Jika tidak berencana untuk menyimpan resource yang Anda buat dalam prosedur ini, buatlah project, bukan memilih project yang ada. Setelah menyelesaikan langkah ini, Anda dapat menghapus project, yang menghapus semua resource yang terkait dengan project ini.

   Buka pemilih project

7. Pastikan penagihan telah diaktifkan untuk project Google Cloud Anda.

8. Enable the Cloud Build, Cloud Run, Cloud Storage, Eventarc, and Workflows APIs.

   Enable the APIs

9. Buat akun layanan:

   1. Di konsol Google Cloud, buka halaman Buat akun layanan.

      Buka Create service account
   2. Pilih project Anda.

   3. Di kolom Nama akun layanan, masukkan nama. Konsol Google Cloud akan mengisi kolom ID akun layanan berdasarkan nama ini.

      Di kolom Deskripsi akun layanan, masukkan sebuah deskripsi. Sebagai contoh, Service account for quickstart.

   4. Klik Buat dan lanjutkan.

   5. Berikan peran berikut ke akun layanan: Cloud Run Admin, Eventarc Event Receiver, Logs Writer, Storage Object Creator, Workflows Invoker.

      Untuk memberikan peran, temukan daftar Pilih peran, lalu pilih peran.

      Untuk memberikan peran tambahan, klik Tambahkan peran lain, lalu tambahkan setiap peran tambahan.

      Catatan: Kolom Peran memengaruhi resource mana yang dapat diakses oleh akun layanan di project Anda. Anda dapat mencabut peran ini atau memberikan peran tambahan di lain waktu. Dalam lingkungan produksi, jangan berikan peran Owner, Editor, atau Viewer. Sebagai gantinya, berikan peran standar atau peran khusus yang memenuhi kebutuhan Anda.
   6. Klik Lanjutkan.

   7. Klik Selesai untuk menyelesaikan pembuatan akun layanan.

10. Jika Anda mengaktifkan agen layanan Cloud Pub/Sub pada atau sebelum 8 April 2021, untuk mendukung permintaan push Pub/Sub yang diautentikasi, berikan peran Service Account Token Creator (roles/iam.serviceAccountTokenCreator) ke akun layanan yang dikelola Google. Jika tidak, peran ini diberikan secara default:
    1. Di Konsol Google Cloud, buka halaman IAM.
       

       Buka IAM

    2. Centang kotak Sertakan pemberian peran yang disediakan Google.
    3. Di kolom Name, cari Akun Layanan Cloud Pub/Sub, lalu klik Edit entity utama di baris yang sesuai.
    4. Klik Tambahkan peran atau Tambahkan peran lain.
    5. Pada daftar Select a role, filter untuk Service Account Token Creator, lalu pilih peran.
    6. Klik Save.

11. Di konsol Google Cloud, aktifkan Cloud Shell.

    Aktifkan Cloud Shell

    Di bagian bawah Google Cloud Console, Cloud Shell sesi akan terbuka dan menampilkan perintah command line. Cloud Shell adalah lingkungan shell dengan Google Cloud CLI yang sudah terinstal, dan dengan nilai yang sudah ditetapkan untuk project Anda saat ini. Diperlukan waktu beberapa detik untuk melakukan inisialisasi sesi.

Cloud Shell mendukung langkah-langkah command line dalam tutorial ini.

gcloud

1. Login ke akun Google Cloud Anda. Jika Anda baru menggunakan Google Cloud, buat akun untuk mengevaluasi performa produk kami dalam skenario dunia nyata. Pelanggan baru juga mendapatkan kredit gratis senilai $300 untuk menjalankan, menguji, dan men-deploy workload.
2. Menginstal Google Cloud CLI.

3. Untuk initialize gcloud CLI, jalankan perintah berikut:

   gcloud init

4. Buat atau pilih project Google Cloud.

   Catatan: Jika tidak berencana untuk menyimpan resource yang Anda buat dalam prosedur ini, buatlah project, bukan memilih project yang ada. Setelah menyelesaikan langkah ini, Anda dapat menghapus project, yang menghapus semua resource yang terkait dengan project ini.

   • Membuat project Google Cloud:

     gcloud projects create PROJECT_ID

     Ganti PROJECT_ID dengan nama untuk project Google Cloud yang Anda buat.

   • Pilih project Google Cloud yang Anda buat:

     gcloud config set project PROJECT_ID

     Ganti PROJECT_ID dengan nama project Google Cloud Anda.

5. Pastikan penagihan telah diaktifkan untuk project Google Cloud Anda.

6. Enable the Cloud Build, Cloud Run, Cloud Storage, Eventarc, and Workflows APIs:

   gcloud services enable cloudbuild.googleapis.com run.googleapis.com storage.googleapis.com eventarc.googleapis.com workflows.googleapis.com

7. Menyiapkan autentikasi:

   1. Buat akun layanan:

      gcloud iam service-accounts create SERVICE_ACCOUNT_NAME

      Ganti SERVICE_ACCOUNT_NAME dengan nama untuk akun layanan.

   2. Memberikan peran ke akun layanan. Jalankan perintah berikut satu kali untuk setiap peran IAM berikut: roles/eventarc.eventReceiver, roles/logging.logWriter, roles/run.admin, roles/storage.objectCreator, roles/workflows.invoker :

      gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=ROLE

      Ganti kode berikut:

      • SERVICE_ACCOUNT_NAME: nama dari akun layanan.
      • PROJECT_ID: project ID dimana Anda membuat akun layanan
      • ROLE: peran yang akan diberikan
      Catatan: Flag --role memengaruhi resource mana saja yang dapat diakses oleh akun layanan dalam proyek Anda. Anda dapat mencabut peran ini atau memberikan peran tambahan di lain waktu. Dalam lingkungan produksi, jangan berikan peran Owner, Editor, atau Viewer. Sebagai gantinya, berikan peran standar atau peran khusus yang memenuhi kebutuhan Anda.
8. Menginstal Google Cloud CLI.

9. Untuk initialize gcloud CLI, jalankan perintah berikut:

   gcloud init

10. Buat atau pilih project Google Cloud.

    Catatan: Jika tidak berencana untuk menyimpan resource yang Anda buat dalam prosedur ini, buatlah project, bukan memilih project yang ada. Setelah menyelesaikan langkah ini, Anda dapat menghapus project, yang menghapus semua resource yang terkait dengan project ini.

    • Membuat project Google Cloud:

      gcloud projects create PROJECT_ID

      Ganti PROJECT_ID dengan nama untuk project Google Cloud yang Anda buat.

    • Pilih project Google Cloud yang Anda buat:

      gcloud config set project PROJECT_ID

      Ganti PROJECT_ID dengan nama project Google Cloud Anda.

11. Pastikan penagihan telah diaktifkan untuk project Google Cloud Anda.

12. Enable the Cloud Build, Cloud Run, Cloud Storage, Eventarc, and Workflows APIs:

    gcloud services enable cloudbuild.googleapis.com run.googleapis.com storage.googleapis.com eventarc.googleapis.com workflows.googleapis.com

13. Menyiapkan autentikasi:

    1. Buat akun layanan:

       gcloud iam service-accounts create SERVICE_ACCOUNT_NAME

       Ganti SERVICE_ACCOUNT_NAME dengan nama untuk akun layanan.

    2. Memberikan peran ke akun layanan. Jalankan perintah berikut satu kali untuk setiap peran IAM berikut: roles/eventarc.eventReceiver, roles/logging.logWriter, roles/run.admin, roles/storage.objectCreator, roles/workflows.invoker :

       gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=ROLE

       Ganti kode berikut:

       • SERVICE_ACCOUNT_NAME: nama dari akun layanan.
       • PROJECT_ID: project ID dimana Anda membuat akun layanan
       • ROLE: peran yang akan diberikan
       Catatan: Flag --role memengaruhi resource mana saja yang dapat diakses oleh akun layanan dalam proyek Anda. Anda dapat mencabut peran ini atau memberikan peran tambahan di lain waktu. Dalam lingkungan produksi, jangan berikan peran Owner, Editor, atau Viewer. Sebagai gantinya, berikan peran standar atau peran khusus yang memenuhi kebutuhan Anda.
14. Jika Anda mengaktifkan agen layanan Cloud Pub/Sub pada atau sebelum 8 April 2021, untuk mendukung permintaan push Pub/Sub yang diautentikasi, berikan peran Service Account Token Creator (roles/iam.serviceAccountTokenCreator) ke akun layanan yang dikelola Google. Jika tidak, peran ini akan diberikan secara default:

    gcloud projects add-iam-policy-binding PROJECT_ID \
        --member=serviceAccount:[e-mail] \
        --role=roles/iam.serviceAccountTokenCreator

Ganti PROJECT_NUMBER dengan nomor project Google Cloud Anda. Anda dapat menemukan nomor project di halaman Welcome pada Google Cloud Console atau dengan menjalankan perintah berikut:

gcloud projects describe PROJECT_ID --format='value(projectNumber)'

Membuat tugas Cloud Run

Tutorial ini menggunakan kode contoh yang dapat Anda temukan di GitHub. Skrip deployment membangun image container untuk membuat tugas Cloud Run. Skrip ini juga akan membuat bucket Cloud Storage. Tugas Cloud Run membaca data peristiwa yang tersimpan di bucket Cloud Storage, lalu mencetak data peristiwa.

1. Dapatkan kode contoh dengan meng-clone repositori aplikasi contoh ke mesin lokal Anda:

   git clone https://github.com/GoogleCloudPlatform/workflows-demos.git
   

   Atau, Anda dapat mendownload contoh sebagai file ZIP

2. Ubah ke direktori yang berisi kode contoh:

   cd workflows-demos/cloud-run-jobs-payload-gcs/message-payload-job
   

3. Buat tugas Cloud Run dengan menjalankan skrip deployment:

   ./deploy-job.sh
   

Skrip ini membuat bucket Cloud Storage dengan nama message-payload-PROJECT_ID, dengan PROJECT_ID sebagai ID project Google Cloud Anda. Tugas Cloud Run bernama message-payload-job juga dibuat.

Men-deploy alur kerja yang menjalankan tugas Cloud Run

Tentukan dan deploy alur kerja yang menjalankan tugas Cloud Run yang baru saja Anda buat. Definisi alur kerja terdiri dari serangkaian langkah yang dijelaskan menggunakan sintaksis alur kerja.

Alur kerja ini menerima peristiwa, menyimpan data peristiwa ke bucket Cloud Storage, lalu menjalankan tugas Cloud Run untuk memproses data peristiwa.

Konsol

1. Di konsol Google Cloud, buka halaman Workflows:

   Buka Workflows

2. Klik Buat.

3. Masukkan nama untuk alur kerja baru, seperti message-payload-workflow.

4. Pilih wilayah yang sesuai; misalnya, us-central1.

5. Di kolom Service account, pilih akun layanan yang Anda buat sebelumnya.

   Akun layanan berfungsi sebagai identitas alur kerja. Anda seharusnya sudah memberikan peran berikut ke akun layanan:

   • Cloud Run Admin: untuk menjalankan tugas Cloud Run
   • Logs Writer: untuk menulis entri log
   • Storage Object Creator: untuk membuat objek di Cloud Storage

6. Klik Next.

7. Di editor alur kerja, masukkan definisi berikut untuk alur kerja Anda:

   main:
       params: [event]
       steps:
           - init:
               assign:
                   - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                   - event_bucket: ${"message-payload-" + project_id}
                   - event_file: ${event.id + ".data.json"}
                   - job_name: message-payload-job
                   - job_location: us-central1
           - log_event:
               call: sys.log
               args:
                   data: ${event}
           - write_payload_to_gcs:
               call: http.post
               args:
                   url: ${"https://storage.googleapis.com/upload/storage/v1/b/" + event_bucket + "/o"}
                   auth:
                       type: OAuth2
                   query:
                       name: ${event_file}
                   body:
                       ${event.data}
           - run_job_to_process_payload:
               call: googleapis.run.v1.namespaces.jobs.run
               args:
                   name: ${"namespaces/" + project_id + "/jobs/" + job_name}
                   location: ${job_location}
                   body:
                       overrides:
                           containerOverrides:
                               env:
                                   - name: INPUT_BUCKET
                                     value: ${event_bucket}
                                   - name: INPUT_FILE
                                     value: ${event_file}
               result: job_execution
           - finish:
               return: ${job_execution}

8. Klik Deploy.

gcloud

1. Buat file kode sumber untuk alur kerja Anda:

   touch message-payload-workflow.yaml
   

2. Salin definisi alur kerja berikut ke message-payload-workflow.yaml:

   main:
       params: [event]
       steps:
           - init:
               assign:
                   - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
                   - event_bucket: ${"message-payload-" + project_id}
                   - event_file: ${event.id + ".data.json"}
                   - job_name: message-payload-job
                   - job_location: us-central1
           - log_event:
               call: sys.log
               args:
                   data: ${event}
           - write_payload_to_gcs:
               call: http.post
               args:
                   url: ${"https://storage.googleapis.com/upload/storage/v1/b/" + event_bucket + "/o"}
                   auth:
                       type: OAuth2
                   query:
                       name: ${event_file}
                   body:
                       ${event.data}
           - run_job_to_process_payload:
               call: googleapis.run.v1.namespaces.jobs.run
               args:
                   name: ${"namespaces/" + project_id + "/jobs/" + job_name}
                   location: ${job_location}
                   body:
                       overrides:
                           containerOverrides:
                               env:
                                   - name: INPUT_BUCKET
                                     value: ${event_bucket}
                                   - name: INPUT_FILE
                                     value: ${event_file}
               result: job_execution
           - finish:
               return: ${job_execution}

3. Deploy alur kerja dengan memasukkan perintah berikut:

   gcloud workflows deploy message-payload-workflow \
       --location=us-central1 \
       --source=message-payload-workflow.yaml \
       --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com
   

   Ganti kode berikut:

   • SERVICE_ACCOUNT_NAME: nama akun layanan yang Anda buat sebelumnya
   • PROJECT_ID: ID project Google Cloud Anda

   Akun layanan berfungsi sebagai identitas alur kerja. Anda seharusnya sudah memberikan peran berikut ke akun layanan:

   • roles/logging.logWriter: untuk menulis entri log
   • roles/run.admin: untuk menjalankan tugas Cloud Run
   • roles/storage.objectCreator: untuk membuat objek di Cloud Storage

Alur kerja melakukan hal berikut:

1. Langkah init—Menerima peristiwa sebagai argumen dan menetapkan variabel yang diperlukan.

2. Langkah log_event—Membuat entri log di Cloud Logging menggunakan fungsi, sys.log.

3. Langkah write_payload_to_gcs—Membuat permintaan POST HTTP dan menulis data payload peristiwa ke file bucket Cloud Storage.

4. Langkah run_job_to_process_payload—Menggunakan metode konektor Cloud Run Admin API, googleapis.run.v1.namespaces.jobs.run, untuk menjalankan tugas. Bucket Cloud Storage dan nama file data diteruskan sebagai variabel pengganti dari alur kerja ke tugas.

5. Langkah finish—Menampilkan informasi tentang eksekusi tugas sebagai hasil dari alur kerja.

Membuat topik Pub/Sub

Membuat topik Pub/Sub sehingga Anda dapat memublikasikan pesan ke topik tersebut. Peristiwa Pub/Sub digunakan untuk mendemonstrasikan cara merutekan peristiwa menggunakan Workflows dan menyimpan peristiwa ke Cloud Storage sehingga tugas Cloud Run dapat memproses data peristiwa tersebut.

Konsol

1. Di konsol Google Cloud, buka halaman Topics.

   Buka Topik

2. Klik CREATE TOPIC.

3. Di kolom Topic ID, masukkan ID untuk topik, seperti message-payload-topic.

4. Pertahankan opsi Tambahkan langganan default.

5. Jangan pilih opsi lain.

6. Klik Create.

gcloud

Untuk membuat topik dengan ID message-payload-topic, jalankan perintah gcloud pubsub topics create:

gcloud pubsub topics create message-payload-topic

Membuat pemicu Eventarc untuk merutekan peristiwa ke alur kerja

Untuk otomatis menjalankan alur kerja dan tugas Cloud Run, buat pemicu Eventarc yang merespons peristiwa Pub/Sub, dan yang merutekan peristiwa tersebut ke alur kerja. Setiap kali pesan ditulis ke topik Pub/Sub, peristiwa tersebut akan memicu eksekusi alur kerja.

Konsol

1. Di konsol Google Cloud, buka halaman Workflows:

   Buka Workflows

2. Klik nama alur kerja Anda, seperti message-payload-workflow.

3. Di halaman Workflow details, klik Edit.

4. Di halaman Edit Workflow, di bagian Triggers, klik Add new trigger > Eventarc.

   Panel Pemicu Eventarc akan terbuka.

5. Di kolom Nama pemicu, masukkan nama untuk pemicu tersebut, seperti message-payload-trigger.

6. Dari daftar Event provider, pilih Cloud Pub/Sub.

7. Dari daftar Event, pilih google.cloud.pubsub.topic.v1.messagePublished.

8. Dari daftar Select a Cloud Pub/Sub topic, pilih topik Pub/Sub yang Anda buat sebelumnya.

9. Di kolom Service account, pilih akun layanan yang Anda buat sebelumnya.

   Akun layanan berfungsi sebagai identitas pemicu. Anda seharusnya sudah memberikan peran berikut ke akun layanan:

   • Penerima Peristiwa Eventarc: untuk menerima peristiwa
   • Workflows Invoker: untuk menjalankan alur kerja

10. Klik Save trigger.

    Pemicu Eventarc sekarang muncul di bagian Pemicu pada halaman Edit alur kerja.

11. Klik Next.

12. Klik Deploy.

gcloud

Buat pemicu Eventarc dengan menjalankan perintah berikut:

gcloud eventarc triggers create message-payload-trigger \
    --location=us-central1 \
    --destination-workflow=message-payload-workflow \
    --destination-workflow-location=us-central1 \
    --event-filters="type=google.cloud.pubsub.topic.v1.messagePublished" \
    --transport-topic=projects/PROJECT_ID/topics/message-payload-topic \
    --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com

Ganti kode berikut:

• PROJECT_ID: ID project Google Cloud Anda
• SERVICE_ACCOUNT_NAME: nama akun layanan yang Anda buat sebelumnya.

Akun layanan berfungsi sebagai identitas pemicu. Anda seharusnya sudah memberikan peran berikut ke akun layanan:

• roles/eventarc.eventReceiver: untuk menerima peristiwa
• roles/workflows.invoker: untuk menjalankan alur kerja

Memicu alur kerja

Uji sistem menyeluruh dengan memublikasikan pesan ke topik Pub/Sub dan membuat peristiwa. Untuk mengetahui informasi selengkapnya, lihat memicu alur kerja dengan peristiwa atau pesan Pub/Sub.

1. Publikasikan pesan ke topik Pub/Sub untuk membuat peristiwa:

   gcloud pubsub topics publish message-payload-topic --message="Hello World"
   

   Peristiwa dirutekan ke alur kerja yang mencatat pesan peristiwa ke dalam log, menyimpan data peristiwa ke bucket Cloud Storage, dan menjalankan tugas Cloud Run untuk memproses data yang tersimpan di Cloud Storage. Proses ini mungkin perlu waktu beberapa saat.

2. Pastikan tugas Cloud Run berjalan seperti yang diharapkan dengan melihat eksekusi tugas:

   gcloud run jobs executions list --job=message-payload-job
   

   Anda akan melihat eksekusi tugas baru di output.

3. Untuk melihat entri log terkait peristiwa yang dibuat dengan memicu alur kerja, jalankan perintah berikut:

   gcloud logging read "resource.type=cloud_run_job AND textPayload:Payload"
   

4. Cari entri log yang mirip dengan:

   textPayload: "Payload: {'message': {'data': 'SGVsbG8gV29ybGQ=', 'messageId': '8834108235224238',\
   \ 'publishTime': '2023-09-20T17:07:52.921Z'}, 'subscription': 'projects/MY_PROJECT/subscriptions/eventarc-us-central1-message-payload-trigger-sub-741'}"
   ...
   resource:
   labels:
     job_name: message-payload-job
     location: us-central1
     project_id: MY_PROJECT
   type: cloud_run_job
   textPayload: Processing message payload gs://message-payload-MY_PROJECT/8254002311197919.data.json
   

5. Anda dapat mengonfirmasi bahwa hasilnya sesuai harapan dengan melihat data peristiwa di objek bucket Cloud Storage.

   1. Ambil nama bucket Anda:

      gsutil ls

      Outputnya mirip dengan hal berikut ini:

      gs://message-payload-PROJECT_ID/

   2. Buat daftar objek dalam bucket:

      gsutil ls -r gs://message-payload-PROJECT_ID/**

      Outputnya akan mirip dengan berikut ini:

      gs://message-payload-PROJECT_ID/OBJECT_ID.data.json

      Catat OBJECT_ID yang akan digunakan di langkah berikutnya.

   3. Download objek dalam bucket sebagai file:

      gcloud storage cp gs://message-payload-PROJECT_ID/OBJECT_ID.data.json message-event.txt

      Ganti OBJECT_ID dengan ID yang ditampilkan di langkah sebelumnya.

   4. Di editor teks, buka file message-event.txt. Isi peristiwa yang ditulis ke file harus mirip dengan yang berikut:

      {
        "message": {
          "data": "SGVsbG8gV29ybGQ=",
          "messageId": "8254002311197919",
          "publishTime": "2023-09-20T16:54:29.312Z"
        },
        "subscription": "projects/MY_PROJECT/subscriptions/eventarc-us-central1-message-payload-trigger-sub-741"
      }
      

      Perlu diperhatikan bahwa jika Anda mendekode nilai data SGVsbG8gV29ybGQ= dari format Base64, "Hello World" akan ditampilkan.

Pembersihan

Jika Anda membuat project baru untuk tutorial ini, hapus project tersebut. Jika Anda menggunakan project yang ada dan ingin mempertahankannya tanpa perubahan yang ditambahkan dalam tutorial ini, hapus resource yang dibuat untuk tutorial.

Menghapus project

Cara termudah untuk menghilangkan penagihan adalah dengan menghapus project yang Anda buat untuk tutorial.

Untuk menghapus project:

Perhatian: Menghapus project memiliki efek berikut:

• Semua hal dalam project akan dihapus. Jika menggunakan project yang sudah ada untuk tugas dalam dokumen ini, saat Anda menghapusnya, pekerjaan lain yang telah Anda lakukan dalam project tersebut juga akan terhapus.
• Project ID kustom hilang. Saat membuat project ini, Anda mungkin telah membuat project ID kustom yang ingin digunakan di masa mendatang. Untuk mempertahankan URL yang menggunakan project ID, seperti URL appspot.com, hapus resource yang dipilih di dalam project, bukan menghapus seluruh project.

Jika Anda berencana mempelajari berbagai arsitektur, tutorial, atau panduan memulai, menggunakan kembali project dapat membantu agar Anda tidak melampaui batas kuota project.

1. Di konsol Google Cloud, buka halaman Manage resource.

   Buka Manage resource

2. Pada daftar project, pilih project yang ingin Anda hapus, lalu klik Delete.
3. Pada dialog, ketik project ID, lalu klik Shut down untuk menghapus project.

Menghapus resource tutorial

Hapus resource yang Anda buat dalam tutorial ini:

1. Hapus topik Pub/Sub.

2. Hapus pemicu Eventarc.

3. Hapus alur kerja Workflows.

4. Hapus tugas Cloud Run.

5. Hapus bucket Cloud Storage.

Langkah selanjutnya

• Pelajari tugas Cloud Run lebih lanjut.
• Pelajari lebih lanjut konektor Workflows.
• Pelajari Workflows lebih lanjut.