Mencoba kembali peristiwa

Eventarc Standard mendukung pengiriman peristiwa minimal satu kali. Artinya, jika tujuan gagal mengonfirmasi peristiwa, Eventarc akan otomatis mencoba mengirim ulang peristiwa tersebut.

Karakteristik percobaan ulang Eventarc Standar cocok dengan karakteristik lapisan transportasinya, Cloud Pub/Sub, yang menangani kegagalan pemrosesan dengan menggunakan kebijakan percobaan ulang langganan.

Cara kerja percobaan ulang

Saat Anda membuat pemicu Eventarc, topik dan langganan transport Pub/Sub akan dibuat secara otomatis untuk Anda. (Peristiwa dari sumber Pub/Sub dapat menggunakan topik Pub/Sub yang ada.) Semua ID langganan yang dibuat secara otomatis oleh Eventarc akan memiliki format yang dimulai dengan eventarc-REGION-.

Secara default, saat tujuan tidak dapat mengonfirmasi pesan, Pub/Sub akan mengirim pesan lagi dengan penundaan backoff eksponensial. Backoff eksponensial memungkinkan Anda menambahkan penundaan yang semakin lama di antara upaya percobaan ulang. Penundaan default dimulai dari minimal 10 detik dan meningkat dengan setiap kegagalan berikutnya, hingga maksimum 600 detik. Eventarc menetapkan durasi retensi pesan default ke 24 jam.

Untuk mengetahui informasi selengkapnya tentang cara Pub/Sub menangani percobaan ulang, lihat Menangani kegagalan pesan dan Permintaan percobaan ulang.

Praktik terbaik untuk menangani percobaan ulang

Jika pesan peristiwa tidak dapat dikirimkan dengan berhasil dalam periode retensi pesan, pesan tersebut akan dibuang kecuali jika topik pesan yang tidak terkirim dikonfigurasi. Topik pesan yang tidak terkirim memungkinkan Anda menyimpan dan menganalisis kegagalan persisten. Dalam dokumen ini, lihat Topik yang dihentikan pengirimannya.

Karena pengiriman setidaknya sekali, pengendali peristiwa Anda mungkin menerima peristiwa duplikat. Praktik terbaiknya adalah mendesain handler agar bersifat idempoten. Dalam dokumen ini, lihat Pengendali peristiwa idempoten.

Mengonfigurasi percobaan ulang

Anda mungkin ingin menyesuaikan perilaku percobaan ulang default. Semua setelan percobaan ulang dan retensi dikonfigurasi melalui kebijakan percobaan ulang langganan Pub/Sub yang terkait dengan pemicu Eventarc Anda.

Untuk mengubah kebijakan percobaan ulang langganan, identifikasi terlebih dahulu langganan Pub/Sub yang terkait dengan pemicu Eventarc Anda. Kemudian, perbarui langganan itu sendiri.

Untuk mengetahui informasi selengkapnya tentang properti langganan, lihat Properti langganan. Untuk mengetahui informasi tentang batas langganan, lihat batas resource Pub/Sub.

Mengidentifikasi langganan

Untuk mengidentifikasi langganan Pub/Sub yang terkait dengan pemicu Eventarc, lakukan hal berikut:

gcloud eventarc triggers describe TRIGGER_NAME \
    --location=LOCATION

  createTime: '2023-03-16T13:40:44.889670204Z'
  destination:
    cloudRun:
      path: /
      region: us-central1
      service: hello
  eventDataContentType: application/protobuf
  eventFilters:
  ...
  transport:
    pubsub:
      subscription: projects/PROJECT_ID/subscriptions/SUBSCRIPTION_ID
      topic: projects/PROJECT_ID/topics/TOPIC_ID

terraform state show google_eventarc_trigger.default

# google_eventarc_trigger.default:
resource "google_eventarc_trigger" "default" {
    conditions              = {}
    create_time             = "2025-07-14T17:29:22.575033822Z"
    effective_labels        = {
        "goog-terraform-provisioned" = "true"
    }
    ...
    transport {
        pubsub {
            subscription = "projects/PROJECT_ID/subscriptions/SUBSCRIPTION_ID"
            topic        = "projects/PROJECT_ID/topics/TOPIC_ID"
        }
    }
}

curl -X GET \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://eventarc.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/triggers/TRIGGER_NAME"

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://eventarc.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/triggers/TRIGGER_NAME" | Select-Object -Expand Content

{
  "name": "projects/PROJECT_ID/locations/LOCATION/triggers/TRIGGER_NAME",
  "uid": "d700773a-698b-47b2-a712-2ee10b690062",
  "createTime": "2022-12-06T22:44:04.744001514Z",
  "updateTime": "2022-12-06T22:44:09.116459550Z",
  "eventFilters": [
    {
      "attribute": "type",
      "value": "google.cloud.pubsub.topic.v1.messagePublished"
    }
  ],
  "serviceAccount": "SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com",
  "destination": {
    "workflow": "projects/PROJECT_ID/locations/LOCATION/workflows/WORKFLOW_NAME"
  },
  "transport": {
    "pubsub": {
      "topic": "projects/PROJECT_ID/topics/TOPIC_ID",
      "subscription": "projects/PROJECT_ID/subscriptions/SUBSCRIPTION_ID"
    }
  }
}

Memperbarui langganan

Untuk memperbarui kebijakan percobaan ulang langganan Pub/Sub yang terkait dengan pemicu Eventarc, lakukan hal berikut:

gcloud pubsub subscriptions update SUBSCRIPTION_ID \
    --min-retry-delay=MIN_RETRY_DELAY \
    --max-retry-delay=MAX_RETRY_DELAY

import {
  to = google_pubsub_subscription.default
  id = "SUBSCRIPTION_ID"
}

resource "google_pubsub_subscription" "default" {
  name  = "SUBSCRIPTION_ID"
  topic = "TOPIC_ID"
  retry_policy {
    minimum_backoff = "MIN_RETRY_DELAYs"
    maximum_backoff = "MAX_RETRY_DELAYs"
  }
  lifecycle {
    # Ignore push delivery configuration which is managed by Eventarc
    ignore_changes = [push_config]
  }
}

{
  "subscription": {
    "retryPolicy": {
      "minimumBackoff": "MIN_RETRY_DELAYs",
      "maximumBackoff": "MAX_RETRY_DELAYs"
    }
  },
  "updateMask": "retry_policy.maximum_backoff,retry_policy.minimum_backoff"
}

cat > request.json << 'EOF'
{
  "subscription": {
    "retryPolicy": {
      "minimumBackoff": "MIN_RETRY_DELAYs",
      "maximumBackoff": "MAX_RETRY_DELAYs"
    }
  },
  "updateMask": "retry_policy.maximum_backoff,retry_policy.minimum_backoff"
}
EOF

curl -X PATCH \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d @request.json \
     "https://pubsub.googleapis.com/v1/projects/PROJECT_ID/subscriptions/SUBSCRIPTION_ID"

@'
{
  "subscription": {
    "retryPolicy": {
      "minimumBackoff": "MIN_RETRY_DELAYs",
      "maximumBackoff": "MAX_RETRY_DELAYs"
    }
  },
  "updateMask": "retry_policy.maximum_backoff,retry_policy.minimum_backoff"
}
'@  | Out-File -FilePath request.json -Encoding utf8

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method PATCH `
    -Headers $headers `
    -ContentType: "application/json; charset=utf-8" `
    -InFile request.json `
    -Uri "https://pubsub.googleapis.com/v1/projects/PROJECT_ID/subscriptions/SUBSCRIPTION_ID" | Select-Object -Expand Content

{
  "name": "projects/PROJECT_ID/subscriptions/SUBSCRIPTION_ID",
  "topic": "projects/PROJECT_ID/topics/TOPIC_ID",
  ...
  "retryPolicy": {
    "minimumBackoff": "MIN_RETRY_DELAYs",
    "maximumBackoff": "MAX_RETRY_DELAYs"
  },
  "state": "ACTIVE"
}

Pertimbangan percobaan ulang lainnya

Anda harus mengetahui pertimbangan berikut saat menangani kegagalan pemrosesan atau meneruskan pesan yang tidak terkirim.

Penundaan push

Jika pelanggan push mengirim terlalu banyak konfirmasi negatif, Pub/Sub mungkin mulai mengirim pesan menggunakan penundaan push. Saat Pub/Sub menggunakan penundaan push, Pub/Sub akan berhenti mengirimkan pesan selama jangka waktu yang telah ditentukan. Rentang waktu ini dapat berkisar antara 100 milidetik hingga 60 detik. Setelah waktu berlalu, Pub/Sub akan mulai mengirimkan pesan lagi. Untuk mengetahui informasi selengkapnya, lihat Penerapan kembali eksponensial.

Topik yang dihentikan pengirimannya

Jika tujuan tidak menerima pesan, Anda dapat meneruskan pesan yang tidak terkirim ke topik yang dihentikan pengirimannya (juga dikenal sebagai antrean pesan yang dihentikan pengirimannya). Topik pesan yang tidak terkirim dapat menyimpan pesan yang tidak dapat dikonfirmasi oleh tujuan. Anda harus menetapkan topik pesan yang tidak terkirim saat membuat atau memperbarui langganan Pub/Sub, bukan saat membuat topik Pub/Sub atau saat Eventarc membuat topik Pub/Sub. Untuk informasi selengkapnya, lihat Mengonfigurasi topik yang dihentikan pengirimannya.

Error yang tidak memerlukan percobaan ulang

Jika aplikasi menggunakan Pub/Sub sebagai sumber peristiwa dan peristiwa tidak dikirim, peristiwa akan otomatis dicoba lagi, kecuali untuk error yang tidak memerlukan percobaan ulang. Peristiwa ke tujuan Workflows dari sumber mana pun tidak akan dicoba lagi jika alur kerja tidak dijalankan. Perhatikan bahwa Workflows akan mengonfirmasi peristiwa segera setelah eksekusi alur kerja dimulai. Jika eksekusi alur kerja dimulai, tetapi kemudian gagal, eksekusi tidak akan dicoba lagi. Untuk mengatasi masalah layanan tersebut, Anda harus menangani error dan coba lagi dalam alur kerja.

Acara duplikat

Peristiwa duplikat mungkin dikirim ke pengendali peristiwa. Menurut spesifikasi CloudEvents, kombinasi atribut source dan id dianggap unik, dan oleh karena itu, setiap peristiwa dengan kombinasi yang sama dianggap duplikat. Anda harus menerapkan handler peristiwa idempoten sebagai praktik terbaik umum.

Pengendali peristiwa idempoten

Pengendali peristiwa yang dapat dicoba ulang harus bersifat idempoten, menggunakan panduan umum berikut:

• Banyak API eksternal yang dapat Anda gunakan untuk menyuplai kunci idempotensi sebagai parameter. Jika Anda menggunakan API seperti itu, Anda harus menggunakan ID peristiwa sebagai kunci idempotensi.
• Idempotensi berfungsi dengan baik pada pengiriman "setidaknya sekali" karena memberikan keamanan untuk mencoba ulang. Jadi, salah satu praktik terbaik yang umum untuk menulis kode tepercaya adalah dengan menggabungkan idempotensi dengan percobaan ulang.
• Pastikan kode Anda idempoten secara internal. Contoh:
  • Pastikan mutasi bisa terjadi lebih dari sekali tanpa mengubah hasilnya.
  • Jalankan kueri pada status database dalam transaksi sebelum memutasikan status tersebut.
  • Pastikan semua efek samping bersifat idempoten.
• Lakukan pemeriksaan transaksi di luar layanan Anda, terlepas dari kode. Sebagai contoh, pertahankan status di suatu tempat yang mencatat bahwa ID peristiwa tertentu telah diproses.
• Tangani panggilan duplikat yang tidak umum. Misalnya, jalankan proses pembersihan terpisah yang akan melakukan pembersihan setelah panggilan duplikat.