Elasticsearch にデータを送信する

概要

ここでは、Insights のリアルタイムのデータエクスポート機能を利用して Elasticsearch にデータを送信し、そのデータを使用してリアルタイムの監視データを Kibana ダッシュボードに入力する方法について説明します。

前提条件

リアルタイムの監視データを Kibana に表示し始める前に、次のホストを設定する必要があります。

Elasticsearch ホストを設定する

Elasticsearch を自身でホストするか、クラウドオプションを使用するかを選択できます。

詳しくは、Elastic の公式 Web サイトをご覧ください。

FileBeat ホストを設定する

概要

FileBeat は、ソース (この場合は Event Hubs) からデータを収集し、Elasticsearch に送信する場合に使用するツールです。

インストール

専用の Filebeat サーバーをホストする必要があります。

FileBeat をインストールするには、まずホストをプロビジョニングし、Elastic の公式 Web サイトに掲載されている、お使いのオペレーティングシステムに合った手順に従ってください。

構成

Filebeat を設定するには、次の手順に従います。

filebeat.ymlファイルを開きます。
Elasticsearch への接続を設定します。
```
cloud.id: "cloud:YOUR_CLOUD_ID"
cloud.auth: "USERNAME:YOUR_PASSWORD"cloud.id: "cloud:YOUR_CLOUD_ID"
cloud.auth: "USERNAME:YOUR_PASSWORD"
```
クラウド ID は Elasticsearch の [Deployments] タブから取得できます。
filebeat.yml ファイルの filebeat.inputs セクションに移動します。

filebeat.inputs セクションに Event Hubs の接続設定を追加します。

<ul>
<li>type: azure-eventhub
  enabled: true
  eventhub: <YOUR EVENTHUB>
  consumer_group: "filebeat"
  connection_string: <YOUR CONNECTION STRING>
  storage_account_key: <YOUR STORAGE ACCOUNT KEY>
  storage_account_container: ""
  resource_manager_endpoint: """</li>
</ul><ul>
<li>type: azure-eventhub
  enabled: true
  eventhub: <YOUR EVENTHUB>
  consumer_group: "filebeat"
  connection_string: <YOUR CONNECTION STRING>
  storage_account_key: <YOUR STORAGE ACCOUNT KEY>
  storage_account_container: ""
  resource_manager_endpoint: """</li>
</ul>

filebeat.yml ファイルの processors セクションに移動します。

processors セクションに以下の行を追加します。

<ul>
<li>decode_json_fields:
      fields: ["message"]
      process_array: false
      max_depth: 2
      target: ""
      overwrite_keys: false
      add_error_key: true</li>
</ul><ul>
<li>decode_json_fields:
      fields: ["message"]
      process_array: false
      max_depth: 2
      target: ""
      overwrite_keys: false
      add_error_key: true</li>
</ul>