MicroStrategy ONE

高スループットまたは詳細アーキテクチャの構成

このトピックでは、Kafka ノード (Telemetry Server) のクラスターを使用して高スループット アーキテクチャを構成する方法について説明します。1 つの Telemetry Store (Platform Analytics) は、単一の Kafka ノードまたは Kakfa クラスターのデータのみを使用できます。

すべての Kafka ノードがクラスター内に存在している必要があり、複数の Kafka クラスターはサポートされていません。

最初に以下のトピックを参照してください。

1. コンポーネントをインストールする

2. テレメトリサーバーを構成する

3. 必要なサービスを再起動する

4. Platform Analytics Consumerを構成する

1. コンポーネントをインストールする

最初に、対応する環境でコンポーネントをインストールします。

  1. インストール ウィザードで、マシン 1、2、3 用に以下のコンポーネントを選択します。

    • MicroStrategy Intelligence

    • MicroStrategy Telemetry Server

    • 選ぶクラスターを作成します... Telemetry 用のクラスター環境を作成するときに、Telemetry をインストールした、またはインストールする予定の他のノードまたはマシンのアドレスを指定します。マシン 1、2、3 でこの手順を繰り返します。

  2. インストール ウィザードで、マシン 4 および 5 用に以下のコンポーネントを選択します。

    • MicroStrategy Intelligence

    • MicroStrategy Telemetry Server

  3. インストール後、MicroStrategy Telemetry Server (Kafka および Zookeeper サービス) をオフにします。

  4. インストール ウィザードで、マシン 6 の次のコンポーネントを選択します。

    • Platform Analytics

    • コンポーネントのインストール時に、リポジトリ (マシン 7) の接続情報を入力する必要があります。

  5. Platform Analytics Repository をマシン 7 にインストールします。すぐに使えるMicroStrategyリポジトリを選択するか、独自のインスタンスを選択することができます。 PostgreSQL データベース サーバー、あなたの組織。

  6. Windows展開の場合は、Platform Analytics サービスを作成するための変更項目 (Windows)それ以外の場合は2. テレメトリサーバーを構成する Linux 展開用。

Platform Analytics サービスを作成するための変更項目 (Windows)

Windows マシンでは、サービスがダウンしないように、Platform Analytics サービスを再作成する必要があります。

  1. [サービス] に移動します。

    1. MicroStrategy Platform Analytics Consumer を停止します。

    2. MicroStrategy Platform Analytics In-Memory Cache を停止します。

  2. MicroStrategy Platform Analytics Consumer サービスを削除します。

    1. 管理権限で Windows コマンド プロンプトを起動します。

    2. 次のコマンドを実行します。

      コピー 
      sc delete MSTR_PlatformAnalyticsConsumer

    3. [サービス] を閉じます。

  3. Platform Analytics Consumer サービスを再作成します。

    1. Platform Analytics ディレクトリに移動します。

    2. 開けるMSTR_PlatformAnalyticsConsumer.config編集用。

    3. 消去--DependesOn =Redis依存サービス (Kafka および Zookeeper) を削除します。

  4. 管理権限で Windows コマンド プロンプトを起動します。

    1. Platform Analytics ディレクトリに移動します。

    2. 次のコマンドを実行します。

      コピー 
      PlatformAnalyticsConsumer.exe install MSTR_PlatformAnalyticsConsumer --Config PlatformAnalyticsConsumer_config.txt

  5. [サービス] に移動します。

    1. MicroStrategy Platform Analytics Consumer を起動します。

    2. 必要に応じて Service Manager を更新します。

2. テレメトリサーバーを構成する

以下の手順に従ってください全てテレメトリ サーバー ノード。この例マシン 1、2、3 を使用します。

server.properties を編集

  1. 開けるserver.properties編集用。

    Windows の場所:

    C:\Program Files (x86)\MicroStrategy\Messaging Services\Kafka\kafka_x.x.xx\config

    Linux の場所:

    /opt/MicroStrategy/MessagingServices/Kafka/kafka_x.x.x./config

  2. 下##### Server Basics ####、ノード フェイルオーバーの優先順序で各 Telemetry サーバー マシンに一意のブローカー ID を提供します。

    この例では、以下の通りです。

    マシン1: broker.id=1
    マシン2: broker.id=2
    マシン3: broker.id=3

    コピー 
    # Set the broker id to a unique value for each node. 
    # Do not change it on the machine configured during single node set up, i.e. your main node. It should be left at the default value and referred to by the other nodes.
    # For example,

    broker.id=1

  3. 下##### Internal Topic Settings ####オフセットとトランザクション状態係数の両方をクラスター内のノード数に設定します。この例では 3 です。

    コピー 
    # offsets.topic.replication.factor= set to the number of nodes in your cluster
    # transaction.state.log.replication.factor= set to the number of nodes in your cluster
    # For example,

    offsets.topic.replication.factor=3
    transaction.state.log.replication.factor=3

  4. 下 ##### Zookeeper #####、すべてのテレメトリサーバーノードのIPアドレスまたはFQDNを追加します。zookeeper.connectパラメータ。ノードの順序は、手順 2 のブローカー ID パラメーターに対応している必要があります。

    コピー 
    # Set zookeeper.connect= to a comma separated list of <IP address:2181> for all nodes in the cluster.
    # For example, 

    zookeeper.connect=10.27.18.73:2181,10.27.18.224:2181,10.27.36.168:2181

zookeeper.properties を編集

  1. 開けるzookeeper.properties編集用。

    Windows の場所:

    C:\Program Files (x86)\MicroStrategy\Messaging Services\Kafka\kafka_x.x.xx\config

    Linux の場所:

    /opt/MicroStrategy/MessagingServices/Kafka/kafka_x.x.x./config

  2. ファイルの末尾に新しい行を追加します。server.node_id=ip:2888:3888。この例では、ノードごとの新しい 3 行があります。

    コピー 
    # To allow Zookeeper to work with the other nodes in your cluster, add the following properties to the end of the zookeeper.properties file.
    # initLimit=5
    # syncLimit=2
    # server.X= <IP address of the node>:2888:3888
    # When adding this property, replace X above with the broker.id for the node being referenced. A separate entry must be made for each node in the cluster.
    # For example,

    initLimit=5
    syncLimit=2
    server.0=10.27.18.73:2888:3888
    server.1=10.27.18.224:2888:3888
    server.2=10.27.36.168:2888:3888

myid を編集

  1. 開けるmyid編集用。このファイルが存在していない場合は作成します。

    Windows の場所:

    C:\Program Files (x86)\MicroStrategy\Messaging Services\tmp\zookeeper

    Linux の場所:

    /opt/MicroStrategy/MessagingServices/tmp/zookeeper

  2. 確認するmyidファイルはない隠し拡張子があります。ファイルエクスプローラーで、ビュー > 見せる > ファイル名拡張子拡張機能を表示します。ファイルに拡張子が付いている場合は削除します。

  3. 必ずbroker.id各ノードが一致する設定した値はserver.properties。

    コピー 
    # Make sure the broker.id is the same as it appears in server.properties.
    # For example,

    broker.id=1

3. 必要なサービスを再起動する

クラスター内のすべてのノードで Kafka と Zookeeper の構成を更新した後、Intelligence Server を含むサービスを再起動する必要があります。

実際に再起動する前に、設定ファイルの変更をすべて済ませておいてください。たとえば、既存の 1 ノードに加え、さらに 2 つの Kafka ノードを追加する場合、3 つのノードすべてについてインストール、設定を終えてから、サービスを再起動することになります。

他のサービスに依存しているものもあるので、以下に示す順序で起動してください。この順序で起動しないと、サービスに不整合が生じることがあります。

  1. まず主ノードで Zookeeper と Kafka を起動し、それから他のノードを起動してください。

  2. 残りのノードで Zookeeper を起動します。

  3. 残りのノードで Kafka を起動します。

4. Platform Analytics Consumerを構成する

Platform Analytics Consumer を実行しているノードで以下の手順を実行します。この例ではマシン 6 です。

  1. 開けるPAConsumerConfig.yaml編集用。

    Windows の場所:

    C:\Program Files (x86)\MicroStrategy\Platform Analytics\conf

    Linux の場所:

    /opt/MicroStrategy/Platform Analytics/conf

  2. 以下の形式で、すべてのテレメトリー ノードの IP アドレスをファイルに追加します。

    zookeeperConnection:IP1:port,IP2:port,IP3:port

    bootstrap.servers: IP1:port,IP2:port,IP3:port

    コピー 
    # Set kafkaTopicNumberOfReplicas: number of nodes in cluster
    # Set zookeeperConnection: <ipAddress:2181> for all nodes in cluster
    # Set bootstrap.servers: <ipAddress:9092> for all nodes in cluster
    # For example,

    kafkaTopicNumberOfReplicas: 3
    zooKeeperConnection: 10.27.18.73:2181,10.27.18.224:2181
    bootstrap.servers: 10.27.18.73:9092,10.27.18.224:9092

  3. 確実にkafkaTopicNumberOfReplicasパラメータはテレメトリ サーバー ノードの数と一致します。この例では 3 です。

  4. 以下のサービスを再起動します。

    • MicroStrategy Platform Analytics Consumer

    • MicroStrategy Platform Analytics In-Memory Cache