サンプルデータを使用した Firehose ストリームのテスト - Amazon Data Firehose
前提条件Amazon S3 を使用してテストするAmazon Redshift を使用してテストするOpenSearch Service を使用してテストするSplunk を使用してテストするApache Iceberg テーブルを使用してテストする

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

サンプルデータを使用した Firehose ストリームのテスト

AWS Management Consoleを使用して、シミュレートされた株価データを取り込むことができます。コンソールによってブラウザでスクリプトが実行されて、サンプルレコードが Firehose ストリームに挿入されます。これにより、独自のテストデータを生成することなく、Firehose ストリームの設定をテストできます。

以下に示しているのは、シミュレートされたデータの例です。

{"TICKER_SYMBOL":"QXZ","SECTOR":"HEALTHCARE","CHANGE":-0.05,"PRICE":84.51}

Firehose ストリームからデータが送信されるときは、標準の Amazon Data Firehose 料金が適用されますが、データが生成されるときは、料金は発生しません。これらの料金の発生を停止するために、いつでもコンソールからサンプルストリームを停止できます。

前提条件

開始する前に、Firehose ストリームを作成します。詳細については、「チュートリアル: コンソールから Firehose ストリームを作成する」を参照してください。

Amazon S3 を使用してテストする

次の手順で、宛先として Amazon Simple Storage Service (Amazon S3) を使用して Firehose ストリームをテストします。

Amazon S3 を使用して Firehose ストリームをテストするには

  1. Firehose コンソール (https://console.aws.amazon.com/firehose/) を開きます。

  2. アクティブな Firehose ストリームを選択します。データの送信を開始する前に、Firehose ストリームのステータスが [アクティブ] になっている必要があります。

  3. [Test with demo data] で、[Start sending demo data] を選択して、サンプル株価データを生成します。

  4. 画面の指示に従って、S3 バケットにデータが配信されていることを確認します。バケットのバッファ設定に基づいて、新しいオブジェクトがバケットに表示されるまでに数分かかる場合があります。

  5. テストが完了したら、[Stop sending demo data] を選択して、利用料金の発生を停止します。

Amazon Redshift を使用してテストする

次の手順で、宛先として Amazon Redshift を使用して Firehose ストリームをテストします。

Amazon Redshift を使用して Firehose ストリームをテストするには

  1. Firehose ストリームでは、Amazon Redshift クラスターにテーブルがあることが必要です。SQL インターフェイスを使用して Amazon Redshift に接続し、以下のステートメントを実行して、サンプルデータを受け入れるテーブルを作成します。

    create table firehose_test_table
(
	TICKER_SYMBOL varchar(4),
	SECTOR varchar(16),
	CHANGE float,
	PRICE float
);

  2. Firehose コンソール (https://console.aws.amazon.com/firehose/) を開きます。

  3. アクティブな Firehose ストリームを選択します。データの送信を開始する前に、Firehose ストリームのステータスが [アクティブ] になっている必要があります。

  4. 新しく作成した firehose_test_table テーブルを参照するように、Firehose ストリームの宛先の詳細を編集します。

  5. [Test with demo data] で、[Start sending demo data] を選択して、サンプル株価データを生成します。

  6. 画面の指示に従って、テーブルにデータが配信されていることを確認します。バッファ設定に基づいて、新しい行がテーブルに表示されるまでに数分かかる場合があります。

  7. テストが完了したら、[Stop sending demo data] を選択して、利用料金の発生を停止します。

  8. 別のテーブルを参照するように、Firehose ストリームの宛先の詳細を編集します。

  9. (オプション) firehose_test_table テーブルを削除します。

OpenSearch Service を使用してテストする

次の手順で、宛先として Amazon OpenSearch Service を使用して Firehose ストリームをテストします。

OpenSearch Service を使用して Firehose ストリームをテストするには

  1. Firehose コンソール (https://console.aws.amazon.com/firehose/) を開きます。

  2. アクティブな Firehose ストリームを選択します。データの送信を開始する前に、Firehose ストリームのステータスが [アクティブ] になっている必要があります。

  3. [Test with demo data] で、[Start sending demo data] を選択して、サンプル株価データを生成します。

  4. 画面の指示に従って、OpenSearch Service ドメインにデータが配信されていることを確認します。詳細については、「Amazon OpenSearch Service デベロッパーガイド」の「Searching Documents in an OpenSearch Service Domain」を参照してください。

  5. テストが完了したら、[Stop sending demo data] を選択して、利用料金の発生を停止します。

Splunk を使用してテストする

次の手順で、宛先として Splunk を使用して Firehose ストリームをテストします。

Splunk を使用して Firehose ストリームをテストするには

  1. Firehose コンソール (https://console.aws.amazon.com/firehose/) を開きます。

  2. アクティブな Firehose ストリームを選択します。データの送信を開始する前に、Firehose ストリームのステータスが [アクティブ] になっている必要があります。

  3. [Test with demo data] で、[Start sending demo data] を選択して、サンプル株価データを生成します。

  4. Splunk インデックスにデータが配信されるかどうかを確認します。Splunk の検索用語の例は sourcetype="aws:firehose:json" および index="name-of-your-splunk-index" です。イベントを検索する方法の詳細については、Splunk のドキュメントの Search Manual を参照してください。

    Splunk インデックスでテストデータが表示されない場合は、Amazon S3 バケットで失敗したイベントを確認します。また、「データが Splunk に配信されない」を参照してください。

  5. テストが完了したら、[Stop sending demo data] を選択して、利用料金の発生を停止します。

Apache Iceberg テーブルを使用してテストする

次の手順で、Apache Iceberg テーブルを宛先として Firehose ストリームをテストします。

Apache Iceberg テーブルを使用して Firehose ストリームをテストするには

  1. Firehose コンソール (https://console.aws.amazon.com/firehose/) を開きます。

  2. アクティブな Firehose ストリームを選択します。データの送信を開始する前に、Firehose ストリームのステータスが [アクティブ] になっている必要があります。

  3. [Test with demo data] で、[Start sending demo data] を選択して、サンプル株価データを生成します。

  4. 画面の指示に従って、データが Apache Iceberg テーブルに配信されていることを検証します。バッファリング設定に基づいて、新しいオブジェクトがバケットに表示されるまでに数分かかる場合があります。

  5. Apache Iceberg テーブルでテストデータが表示されない場合は、Amazon S3 バケットで失敗したイベントを確認します。

  6. テストが完了したら、[Stop sending demo data] を選択して、利用料金の発生を停止します。