Sparkを使用したPortfolio Managerのデモ

Portfolio Managerのデモでは、財務関連のユース・ケースに基づいてアプリケーションが実行されます。株式のポートフォリオを作成するスクリプトを実行します。

Portfolio Managerのデモでは、財務関連のユース・ケースに基づいてアプリケーションが実行されます。株式のポートフォリオを作成するスクリプトを実行します。Cassandra OLTP(オンライン・トランザクション処理)側の各ポートフォリオには、株式の一覧、購入株数、購入価格が含まれています。このデモの株式市況ユーティリティは、リアルタイムで株式データをシミュレーションします。各ポートフォリオは、全体的価値および購入価格比の増減のパーセンテージに基づいて更新されます。このユーティリティは、株式ごとに100日間の市場データの履歴(終値)も生成します。DSE OLAP(オンライン分析処理)側では、Spark Scalaジョブが、ポートフォリオごとに、10日間の履歴データの最大損失を計算します。これがポートフォリオに関連付けられたリスクの標識となります。この情報は顧客が潜在的損失を測定できるように、リアルタイムのアプリケーションに送り返されます。

手順

デモを実行するには:

注: DataStaxのデモは、LDAPまたは内部権限管理(ユーザー名/パスワード)のいずれかを有効にした状態では動作しません。

  1. DataStaxインストーラーを使用して、GUIまたはテキスト・モードで以下の設定を指定し、1つのデモ・ノードをインストールします。
    • Install Options]ページ - デフォルトのインターフェイス:127.0.0.1(デモにこのIPを使用する必要があります。)
    • Node Setup]ページ - ノード・タイプ:Analytics
    • Analytic Node Setup]ページ - Analyticsタイプ:Spark + Integrated Hadoop(廃止予定)
  2. DataStax Enterpriseをまだ起動していない場合は、起動します。
    • Installer-Servicesおよびパッケージのインストール:
      sudo service dse start
    • Installer-No Servicesおよびtarボールのインストール:
      install_location/bin/dse cassandra -k ## ノードをSparkモードで起動します

      デフォルトのinstall_location/usr/share/dseです。

  3. ポートフォリオ・マネージャーのデモ・ディレクトリーに移動します。
    ポートフォリオ・マネージャー・デモのデフォルトの場所は、インストールのタイプによって異なります。
    Installer-Servicesおよびパッケージ・インストール /usr/share/dse/demos/portfolio_manager
    Installer-No Servicesおよびtarボール・インストール install_location/demos/portfolio_manager
  4. bin/pricerユーティリティを実行して、アプリケーションのストック・データを生成します。
    • このユーティリティに使用可能なオプションをすべて表示するには:
      sudo bin/pricer --help
    • pricerユーティリティを起動します。
      sudo bin/pricer -o INSERT_PRICES 
      $ sudo bin/pricer -o UPDATE_PORTFOLIOS 
      $ sudo bin/pricer -o INSERT_HISTORICAL_PRICES -n 100
    pricerユーティリティの実行には数分かかります。
  5. Webサービスを起動します。
    $ cd website
    $ sudo ./start
  6. ブラウザーを開き、http://localhost:8983/portfolioにアクセスします。

    リアルタイムのPortfolio Managerデモ・アプリケーションが表示されます。



  7. 別のターミナルを開きます。
  8. 10-day-loss.shスクリプトを実行してSparkを起動します。
    • Installer-Services: $ cd /usr/share/dse/demos/spark; ./10-day-loss.sh
    • パッケージ・インストール: $ cd /usr/share/dse-demos/spark; ./10-day-loss.sh
    • Installer-No Servicesおよびtarボールのインストール: $ install_location/demos/spark/10-day-loss.sh

    Sparkアプリケーションが実行されるには数分かかります。

  9. ジョブが完了したら、Portfolio Manager Webページを更新します。

    各ポートフォリオの10日間の履歴データの最大損失の結果が表示されます。