一連のキネシスストリームの終わりから終わりまでの時間を計算するlambdas

Question

入力レコードを取り込み、一連のキネシスストリームとラムダを使って一連の変換を適用するシステムがあります。 http://docs.aws.amazon.com/lambda/latest/dg/monitoring-functions.html @>店舗DynamoDBの

に

ラムダCloudWatchのドキュメント与える -

KinesisStream - > InputRecord - > Lambda1/Lambda2並行して実行 - >出力1キネシスストリーム - > Lambda3 - >出力2キネシスストリームラムダメトリックごとに取られた時間の詳細。

しかし、入力レコードがチェーン全体に流れるために要した合計時間に関するメトリックも取得したいと考えています。

誰もがエンドツーエンドのレイテンシを収集するのに似た何かをしましたか？

Answer 1

最後のラムダ（または、その部分を計算したい場合は、DynamoDBのアップデートストリーム）のイベントごとのレイテンシを計算できます。

たとえば、あなたの例のLambda3では、記録に入れたタイムスタンプやKinesisのタイムスタンプを読み取ってdiffをnowから計算し、console.logに書き込むことができます。これらのログはCloudWatchログに書き込まれます。ここでメトリックを定義してCloudWatchに表示し、この待ち時間がSLAしきい値を超えたときに通知するアラームを生成することもできます。