lambda 関数Aでerrorという文字列がログに出た時、関数BをCloudWatchのサブスクリプションフィルターで実行する

概要

• 関数Aでerrorという文字列がログに出力されたら、関数BをCloudWatchのサブスクリプションフィルターを用いて実行する方法を簡単にまとめる。

方法

• 関数Aと関数Bは下記記事で使用した関数A（echo-error）と関数B（hello-world）を使用する。関数Aに若干の修正を加える。関数AのIAMロールに付与したカスタマーポリシーなどはそのままにしてある。

• 関数A（echo-error）を下記の様に修正する。（9行目をコメントアウトするだけ）

  import { LambdaClient, InvokeCommand } from '@aws-sdk/client-lambda';
  
  const lambdaClient = new LambdaClient({ region: 'ap-northeast-1' }); // 適切なリージョンを設定
  
  export async function handler(event) {
    try {
      // 何らかの処理
      console.log('error');
  //    await invokeFunctionB(); // 本当は例外のときに関数Bを呼び出すけど、動作確認のために常に呼び出す
    } catch (error) {
      console.error('error');
      // 関数Bを呼び出す
      await invokeFunctionB();
    }
  }
  
  async function invokeFunctionB() {
    const params = {
      FunctionName: '関数BのARN名',
      InvocationType: 'Event', // 非同期呼び出し
      Payload: JSON.stringify({}), // 関数Bに渡す引数を設定する事もできる
    };
  
    try {
      const command = new InvokeCommand(params);
      const response = await lambdaClient.send(command);
      console.log('Function B invoked:', response);
    } catch (error) {
      console.error('Error invoking Function B:', error);
    }
  }
  

• 一旦、関数Aを実行して、関数Bが実行されないことを確認する。

• CloudWatchで関数Aのロググループを表示する。

• 「サブスクリプションフィルター」を開く。

  

• 「作成」をクリックし「Lambda サブスクリプションフィルター」をクリックする。

• 下記のようにサブスクリプションフィルターを設定する　。

  • Lambda関数：関数B（hello-world）
  • ログ形式：その他
  • サブスクリプションフィルターのパターン：error
  • サブスクリプションフィルター名：error-chatch-subscription-filter

• サブスクリプションフィルターを作成する　。

• 関数Aを実行するとサブスクリプションフィルターを通じて関数Bが実行されるようになる。