Cloud Functionsのリトライ制限

節操のないリトライ

Cloud Functionsには失敗時に再試行する機能があるんです。
ただ、この連コインが節度なく、秒間数回の割合で送られてくるのです。
そのため、例えば、Cloud Functionsからアクセスされるサーバでシステム障害でエラーが出ていた場合、
その様相たるや、永パが際限なく続くようなものであります。

リトライ制限

そのような状況を防ぐには、こうします。
一定時間経ったらリクエストを拒否するようにします。

// 受信メイン処理
func main(ctx context.Context, e GCSEvent) error {
	meta, err := metadata.FromContext(ctx)
	if err != nil {
		return fmt.Errorf("metadata.FromContext: %v", err)
	}

	// メッセージ発行時と現在時を比較して古すぎた場合は処理を終了
	expiration := meta.Timestamp.Add(10 * time.Second)
	if time.Now().After(expiration) {
		log.Printf("event timeout: halting retries for expired event '%q'", meta.EventID)
		return nil
	}

	// メインロジック
	return logic(ctx, e)
}

現場からは以上です。