ステップ 3.2: 入力の設定 - Amazon Kinesis Data Analytics for SQL Applications デベロッパーガイド

新しいプロジェクトでは、Kinesis Data Analytics for Applications 経由で新しい Managed Service for Apache Flink Studio SQL を使用することをお勧めします。Managed Service for Apache Flink Studio は、使いやすさと高度な分析機能を兼ね備えているため、高度なストリーム処理アプリケーションを数分で構築できます。

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

ステップ 3.2: 入力の設定

アプリケーションにはストリーミングソースが必要です。開始しやすくするために、コンソールでデモストリーム (kinesis-analytics-demo-stream といいます) を作成できます。また、コンソールでストリームにレコードを入力するスクリプトが実行されます。

ストリーミングソースをアプリケーションに追加するには

  1. コンソールのアプリケーションハブページで、[ストリーミングデータの接続] を選択します。

    サンプルアプリケーションのスクリーンショットと sourceGS ボタンへの接続。

  2. 表示されたページで、以下を確認します。

    • [Source] セクション。アプリケーションのストリーミングソースを指定します。既存のストリームソースを選択するか、1 つ作成できます。この実習では、新しいストリームとしてデモストリームを作成します。

       

      デフォルトでは、コンソールは作成されたアプリケーション内入力ストリームを INPUT_SQL_STREAM_001 と命名します。この実習では、表示された名前のままにします。

       

      • [ストリームリファレンス名] – このオプションでは、作成されているアプリケーション内入力ストリームの名前 (SOURCE_SQL_STREAM_001) が表示されます。名前は変更できますが、この実習ではこの名前のままにします。

         

        入力設定で、デモストリームを作成したアプリケーション内入力ストリームにマッピングします。アプリケーションを開始すると、Amazon Kinesis Data Analytics はデモストリームを継続的に読み取り、アプリケーション内入力ストリームに行を挿入します。アプリケーションコードでこのアプリケーション内入力ストリームをクエリします。

         

      • を使用したレコードの前処理 AWS Lambda: このオプションは、アプリケーションコードが実行される前に入力ストリームのレコードを変更する AWS Lambda 式を指定する場所です。この演習では、[Disabled] オプションを選択したままにしておきます。Lambda 事前処理の詳細については、「Lambda 関数を使用したデータの事前処理」を参照してください。

    このページのすべての情報を指定すると、コンソールは更新リクエスト (「UpdateApplication」を参照) を送信して入力設定をアプリケーションに追加します。

  3. [Source] ページで、[Configure a new stream] を選択します。

  4. [Create demo stream] を選択します。コンソールで、以下を実行してアプリケーション入力を設定します。

    • コンソールで Kinesis データストリーム (kinesis-analytics-demo-stream) を作成します。

    • コンソールで、株のティッカーデータのサンプルがストリームに入力されます。

    • DiscoverInputSchema 入力アクションを使用して、ストリームのサンプルレコードを読み取って、コンソールでスキーマを推測します。推定されるスキーマは、作成したアプリケーション内入力ストリーム用のスキーマです。詳細については、「アプリケーション入力の設定」を参照してください。

    • コンソールに、推測スキーマと、スキーマを推測するためにストリーミングソースから読み取ったサンプルデータが表示されます。

    コンソールに、ストリーミングソースのサンプルレコードが表示されます。

    タブ区切り形式の株式シンボル、セクターおよび価格を示すフォーマットされたストリームサンプルタブ。

    [Stream sample] コンソールページに次のように表示されます。

    • [Raw stream sample] タブには、スキーマを推測するための、API アクション (DiscoverInputSchema) でサンプリングされた未加工のストリームレコードが表示されます。

    • [Formatted stream sample] タブには、[Raw stream sample] タブのデータの表形式バージョンが表示されます。

    • [Edit schema] を選択すると、推定スキーマを編集することができます。この実習では、推測スキーマを変更しないでください。スキーマの詳細については、「スキーマエディタの使用」を参照してください。

      [Rediscover schema] を選択している場合は、再度「DiscoverInputSchema」を実行してスキーマを推測するようにコンソールにリクエストできます。

  5. [Save and continue] を選択します。

    これで、入力設定が追加されたアプリケーションができました。次のステップでは、SQL コードを追加して、アプリケーション内入力ストリームのデータに分析を実行します。

次のステップ

ステップ 3.3: リアルタイム分析を追加する (アプリケーションコードの追加)