Logstashを使用したOpenSearchクラスタへのデータの取込み
Logstashを使用して、ログ・データをOpenSearchクラスタに収集します。
Logstashは、様々なソースからデータを取り込み、処理および変換し、OpenSearchクラスタなどの宛先に送信できるデータ処理パイプラインです。
前提条件
このトピックで説明するステップに進む前に、次のタスクを完了してください。
- ローカル・マシンにJava Development Kit (JDK) バージョン8またはバージョン11をダウンロードしてインストールします。
-
OpenSearchクラスタを作成し、接続情報をノートにとります。「OpenSearchクラスタの作成」および「OpenSearchクラスタの詳細の取得」を参照してください。
-
コンピュート・インスタンスを作成して接続します。インスタンスは、OpenSearchクラスタと同じVCN内にある必要があります。Creating a VM Instanceを参照してください。
- ローカル・マシンからOpenSearchクラスタに接続します。タスク3: OCI検索サービスへの接続のテスト- OpenSearchエンドポイントを参照してください
LogStashのインストールと構成
OpenSearch Ingest Tools (2.8)からLogstash OSS with OpenSearch Output Pluginをダウンロードし、ローカル・マシンにインストールします。これは現在、LinuxおよびMacOSベースのシステムでのみ使用できます。
ダウンロードしたLogstash tarballを抽出し、
Logstash
ディレクトリに移動します。Logstash
ディレクトリのconfig
サブディレクトリにパイプライン構成ファイルlogstash.conf
を作成します。次に、ローカル・マシンからログ・ファイルを読み取り、ログ・データをOpenSearchクラスタに収集するパイプライン構成ファイルの例を示します。該当するテキストをクラスタの詳細に置き換えます。
host
のクラスタのAPIエンドポイントを指定します。OpenSearchクラスタの詳細の取得を参照してください。user
およびpassword
には、OpenSearchクラスタのデータを収集するための十分な権限を持つユーザーを指定します。たとえば、クラスタの作成時に指定したロールベースのアクセス制御にプライマリ・ユーザー・アカウントを使用できます。「OpenSearchを使用した検索でのロールベースのアクセス制御」を参照してください。input { file{ path => "/path/to/log/file/application.log" start_position => "beginning" } } filter{ #Optional and can be empty } output { opensearch { hosts => "<cluster API endpoint>" user => "<cluster user>" password => "<cluster password>" index => "<index name>" ssl_certificate_verification => true } }
次のコマンドを実行して、Logstashを起動します。
bin/logstash -f config/logstash.conf
Logstashが起動すると、ファイル入力プラグインを使用してファイル・システムに新しいログが継続的に読み取られます。その後、LogstashはOpenSearch出力プラグインを使用して、新しいログ・データをOpenSearchクラスタに収集します。
クラスタのOpenSearchダッシュボードに接続して、index
に指定した名前の索引をパイプライン構成ファイルでチェックすることで、ログ・データがOpenSearchクラスタに収集されたことを確認できます。タスク6: OpenSearchダッシュボードへの接続およびOpenSearchダッシュボードのクイックスタート・ガイドを参照してください。