ステップ 3.4: (オプション) アプリケーションコードを更新する

アプリケーションコードを更新するには

1. 次のように別のアプリケーション内ストリームを作成します。

   • DESTINATION_SQL_STREAM_2 という別のアプリケーション内ストリームを作成します。

   • ポンプを作成し、それを使用して DESTINATION_SQL_STREAM から行を選択して、新しく作成したストリームに行を挿入します。

   SQL エディタで、既存のアプリケーションコードに次のコードを追加します。

   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM_2" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "STREAM_PUMP_2" AS 
      INSERT INTO "DESTINATION_SQL_STREAM_2"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "DESTINATION_SQL_STREAM";

   コードを保存して実行します。追加のアプリケーション内ストリームが [Real-time analytics] タブに表示されます。

2. 2 つのアプリケーション内ストリームを作成します。SOURCE_SQL_STREAM_001 の行を株価ティッカーに基づいてフィルタし、それらを別々のストリームに挿入します。

   アプリケーションコードに次のSQLステートメントを追加します。

   CREATE OR REPLACE STREAM "AMZN_STREAM" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "AMZN_PUMP" AS 
      INSERT INTO "AMZN_STREAM"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  ticker_symbol SIMILAR TO '%AMZN%';
   
   CREATE OR REPLACE STREAM "TGT_STREAM" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "TGT_PUMP" AS 
      INSERT INTO "TGT_STREAM"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  ticker_symbol SIMILAR TO '%TGT%';

   コードを保存して実行します。[Real-time analytics] タブの追加のアプリケーション内ストリームに注意してください。