新規プロジェクトでは、Kinesis Data Analytics for SQL よりも 新しい Managed Service for Apache Flink Studio を使用することをお勧めします。Managed Service for Apache Flink Studio は、使いやすさと高度な分析機能を兼ね備えているため、高度なストリーム処理アプリケーションを数分で構築できます。
翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
ステップ 4: 出力の確認
「ステップ 3: アプリケーション出力を設定する」でアプリケーション出力を設定した後、次の AWS CLI コマンドを使用して、アプリケーションによって書き込まれた宛先ストリームのレコードを読み取ります。
-
get-shard-iterator
コマンドを実行して出力ストリームのデータへのポインタを取得します。aws kinesis get-shard-iterator \ --shard-id shardId-000000000000 \ --shard-iterator-type TRIM_HORIZON \ --stream-name OutputStreamTestingAnomalyScores \ --region us-east-1 \ --profile adminuser
次のレスポンス例に示すように、シャードイテレーター値を含むレスポンスを受け取ります。
{ "ShardIterator": "
shard-iterator-value
" }シャードイテレーター値をコピーします。
-
get-records
AWS CLI コマンドを実行します。aws kinesis get-records \ --shard-iterator
shared-iterator-value
\ --region us-east-1 \ --profile adminuserコマンドはレコードのページと、別のシャードイテレーターを返します。これは後続の
get-records
コマンドで次のレコードのセットを取得するために使用できます。