翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

Amazon CloudWatch Events を使用する

CloudWatch イベントは、 AWS リソースの変更を示すシステムイベントのほぼリアルタイムのストリームを、 Amazon EC2 インスタンス、 Lambda 関数、 Kinesis ストリーム、 Amazon ECS タスク、 Step Functions ステートマシン、 Amazon SNS トピック、 Amazon SQS キュー、または組み込みターゲットに配信します。簡単なルールを使用して、一致したイベントを 1 つ以上のターゲット関数またはストリームに振り分けることができます。

Amazon EventBridge は CloudWatch イベントの進化です。どちらのサービスも同じ API を使用するため、 SDK が提供するCloudWatch イベントクライアントを引き続き使用することも、 SDK for Java の CloudWatch イベント機能用EventBridge クライアントに移行することもできます。 CloudWatch Events ユーザーガイドのドキュメントと API リファレンスは、 EventBridge ドキュメントサイトから利用できるようになりました。

イベントの追加

カスタム CloudWatch イベントを追加するには、各イベントの詳細を提供する 1 つ以上のPutEventsRequestオブジェクトを含む PutEventsRequestEntry オブジェクトで CloudWatchEventsClient’sputEventsメソッドを呼び出します。イベントのソースとタイプ、イベントに関連付けられたリソースなど、エントリの複数のパラメータを指定できます。

インポート

import software.amazon.awssdk.services.cloudwatch.model.CloudWatchException;
import software.amazon.awssdk.services.cloudwatchevents.CloudWatchEventsClient;
import software.amazon.awssdk.services.cloudwatchevents.model.PutEventsRequest;
import software.amazon.awssdk.services.cloudwatchevents.model.PutEventsRequestEntry;

Code

    public static void putCWEvents(CloudWatchEventsClient cwe, String resourceArn ) {

        try {

            final String EVENT_DETAILS =
                "{ \"key1\": \"value1\", \"key2\": \"value2\" }";

            PutEventsRequestEntry requestEntry = PutEventsRequestEntry.builder()
                    .detail(EVENT_DETAILS)
                    .detailType("sampleSubmitted")
                    .resources(resourceArn)
                    .source("aws-sdk-java-cloudwatch-example")
                    .build();

            PutEventsRequest request = PutEventsRequest.builder()
                    .entries(requestEntry)
                    .build();

            cwe.putEvents(request);
            System.out.println("Successfully put CloudWatch event");

        } catch (CloudWatchException e) {
            System.err.println(e.awsErrorDetails().errorMessage());
            System.exit(1);
        }
    }

「」で完全な例を参照してください GitHub。

ルールの追加

ルールを作成または更新するには、ルールの名前とイベントパターン 、ルールに関連付けるロール、ルールの実行頻度を説明するスケジュール式などのオプションパラメータPutRuleRequestを使用して、 CloudWatchEventsClient’sputRuleメソッドを呼び出します。 IAM

インポート

import software.amazon.awssdk.services.cloudwatch.model.CloudWatchException;
import software.amazon.awssdk.services.cloudwatchevents.CloudWatchEventsClient;
import software.amazon.awssdk.services.cloudwatchevents.model.PutRuleRequest;
import software.amazon.awssdk.services.cloudwatchevents.model.PutRuleResponse;
import software.amazon.awssdk.services.cloudwatchevents.model.RuleState;

Code

    public static void putCWRule(CloudWatchEventsClient cwe, String ruleName, String roleArn) {

        try {
            PutRuleRequest request = PutRuleRequest.builder()
                .name(ruleName)
                .roleArn(roleArn)
                .scheduleExpression("rate(5 minutes)")
                .state(RuleState.ENABLED)
                .build();

            PutRuleResponse response = cwe.putRule(request);
            System.out.printf(
                    "Successfully created CloudWatch events rule %s with arn %s",
                    roleArn, response.ruleArn());
        } catch (
            CloudWatchException e) {
            System.err.println(e.awsErrorDetails().errorMessage());
            System.exit(1);
        }
    }

「」で完全な例を参照してください GitHub。

ターゲットの追加

ターゲットは、ルールがトリガーされたときに呼び出されるリソースです。ターゲットの例には、 Amazon EC2 インスタンス、 Lambda 関数、 Kinesis ストリーム、 Amazon ECS タスク、 Step Functions ステートマシン、組み込みターゲットなどがあります。

ルールにターゲットを追加するには、更新するルールPutTargetsRequestを含む と、ルールに追加するターゲットのリストを使用して CloudWatchEventsClient’sputTargetsメソッドを呼び出します。

インポート

import software.amazon.awssdk.services.cloudwatch.model.CloudWatchException;
import software.amazon.awssdk.services.cloudwatchevents.CloudWatchEventsClient;
import software.amazon.awssdk.services.cloudwatchevents.model.PutTargetsRequest;
import software.amazon.awssdk.services.cloudwatchevents.model.PutTargetsResponse;
import software.amazon.awssdk.services.cloudwatchevents.model.Target;

Code

    public static void putCWTargets(CloudWatchEventsClient cwe, String ruleName, String functionArn, String targetId ) {

        try {
            Target target = Target.builder()
                .arn(functionArn)
                .id(targetId)
                .build();

            PutTargetsRequest request = PutTargetsRequest.builder()
                .targets(target)
                .rule(ruleName)
                .build();

            PutTargetsResponse response = cwe.putTargets(request);
            System.out.printf(
                "Successfully created CloudWatch events target for rule %s",
                ruleName);
        } catch (CloudWatchException e) {
            System.err.println(e.awsErrorDetails().errorMessage());
            System.exit(1);
        }
    }

「」で完全な例を参照してください GitHub。

詳細情報