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

Amazon S3 の Apache Iceberg テーブルへの Amazon Data Firehose ストリームの配信はプレビュー中であり、変更される可能性があります。

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

サンプルデータを使用した 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 ストリームの送信先の詳細を編集して、新しく作成されたfirehose_test_tableテーブルを参照します。

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

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

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

  8. Firehose ストリームの送信先の詳細を編集して、別のテーブルをポイントします。

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

OpenSearch サービスでテストする

Amazon OpenSearch Service を送信先として使用して Firehose ストリームをテストするには、次の手順に従います。

OpenSearch サービスを使用して Firehose ストリームをテストするには
  1. で Firehose コンソールを開きますhttps://console.aws.amazon.com/firehose/

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

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

  4. 画面の指示に従って、データが OpenSearch サービスドメインに配信されていることを確認します。詳細については、Amazon OpenSearch Service デベロッパーガイドの「サービスドメインでのドキュメントの検索」を参照してください。 OpenSearch

  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] を選択して、利用料金の発生を停止します。