Lambda でのポーリングとストリームの開始位置 - AWS Lambda

Lambda でのポーリングとストリームの開始位置

StartingPosition パラメータは、ストリームからのメッセージの読み取りを開始するタイミングを Lambda に指示します。選択できるオプションは 3 つあります。

  • 最新 – Lambda は Kafka トピックの最新レコードの直後から読み取りを開始します。

  • 水平線トリミング – Lambda は Kafka トピック内のトリミングされていない最新レコードから読み取りを開始します。これはトピック内の最も古いレコードになります。

  • タイムスタンプで – Lambda は、タイムスタンプで定義された位置 (秒単位のUnix 時間) から読み取りを開始します 。StartingPositionTimestamp パラメータを使用してタイムスタンプを指定します。

イベントソースマッピングの作成時、または更新が最終的に一貫性を持っている場合にポーリングをストリーミングしてください。

  • イベントソースマッピングの作成時、ストリームからのイベントのポーリングが開始されるまでに数分かかる場合があります。

  • イベントソースマッピングの更新時、ストリーミングからのイベントのポーリングの停止と再開に最大 90 秒かかる場合があります。

この挙動のため、LATEST をストリーミング開始位置として指定した場合、作成または更新時にイベントソースマッピングがいくつかのイベントを見逃す可能性があります。イベントが見逃されないようにするには、TRIM_HORIZON または AT_TIMESTAMP を指定してください。