RubyアプリをOpenSearchからElasticsearchに移行する方法

Elasticsearch を実際に体験してみましょう。サンプルノートブックを詳しく調べたり、Elastic の無料クラウドトライアルを開始したり、今すぐローカルマシンで Elastic を試したりできます。

OpenSearch Ruby クライアントは、バージョン7.xの Elasticsearch Ruby クライアントからフォークされたため、コードベースは比較的似ています。つまり、Ruby コードベースを OpenSearch から Elasticsearch に移行すると、それぞれのクライアントライブラリのコードは非常に馴染みのあるものになります。このブログ記事では、OpenSearch を使用する Ruby アプリの例と、このコードを Elasticsearch に移行する手順を紹介します。

どちらのクライアントも、一般的な Apache License 2.0 に基づいてリリースされているため、オープンソースかつフリーソフトウェアです。Elasticsearch のライセンスは最近更新され、Elasticsearch と Kibana のコアはバージョン 8.16 以降、OSI 承認のオープンソースライセンス AGPL に基づいて公開されています。

Rubyアプリの移行時にElasticsearchのバージョンを考慮する

移行時に考慮すべき点の 1 つは、どのバージョンの Elasticsearch を使用するかということです。最新の安定リリース (この記事の執筆時点では8.17.0を使用することをお勧めします。Elasticsearch Ruby クライアントのマイナーバージョンは、Elasticsearch のマイナーバージョンに従います。したがって、Elasticsearch 8.17.xでは、Ruby gem のバージョン8.17.xを使用できます。

OpenSearch は Elasticsearch 7.10.2 からフォークされました。そのため、API が変更され、どちらでも異なる機能が使用される可能性があります。しかし、それはこの記事の範囲外なので、サンプルアプリで最も一般的な操作についてのみ説明します。

Ruby on Rails の場合、公式の Elasticsearch クライアント、またはRails 統合ライブラリを使用できます。Elasticsearch とクライアントの最新の安定バージョンに移行することをお勧めします。elasticsearch-rails gem バージョン8.0.0 Rails 6.1 、 7.0 、 7.1 、および Elasticsearch 8.xをサポートします。

コード

この例では、 tarball から OpenSearch をインストールする手順に従いました。tarball をダウンロードして解凍した後、後でクライアントをインスタンス化するために使用する初期管理者パスワードを設定する必要がありました。

次のようなGemfileを持つディレクトリを作成しました:

bundle installを実行すると、プロジェクトに gem がインストールされます。インストールされた opensearch-ruby バージョン3.4.0と、実行している OpenSearch のバージョンは2.18.0です。同じディレクトリ内のexample_code.rbファイルにコードを記述しました。このファイルの初期コードは、OpenSearch クライアントのインスタンス化です。

テストを容易にするために、ユーザーガイドに従ってトランスポートオプションssl: { verify: false}パラメータが渡されます。本番環境では、OpenSearch の展開に応じてこれを設定する必要があります。

OpenSearch バージョン 2.12.0 以降では、インストールスクリプトを実行するときに、 OPENSEARCH_INITIAL_ADMIN_PASSWORD環境変数を強力なパスワードに設定する必要があります。tarball から OpenSearch をインストールする手順に従って、コンソールで変数をエクスポートし、Ruby スクリプトで使用できるようになりました。

クライアントが OpenSearch に接続していることを確認するための簡単な API は、 cluster.health API を使用しています。

そして実際にそれは機能します:

Elasticsearch Ruby クライアントのドキュメントにある一般的な例をいくつかテストしたところ、期待どおりに動作しました。

RubyアプリをElasticsearchに移行する

最初のステップは、Gemfile にelasticsearch-rubyを追加することです。bundle installを実行すると、Elasticsearch Ruby クライアント gem がインストールされます。完全に移行する前にコードをテストしたい場合は、最初はopensearch-ruby gem をそこに残しておくことができます。

次の重要なステップは、クライアントのインスタンス化です。これは、Elasticsearch をどのように実行しているかによって異なります。これらの例に対して同様のアプローチを維持するために、「Elasticsearch をダウンロードしてローカルで実行する」の手順に従います。

bin/elasticsearchを実行すると、Elasticsearch は自動的に構成されたセキュリティ機能で起動します。必ず elastic ユーザーのパスワードをコピーしてください (ただし、 bin/elasticsearch-reset-password -u elasticを実行してリセットできます)。この例に従う場合は、OpenSearch と Elasticsearch は同じポートで実行されるため、Elasticsearch を起動する前に必ず OpenSearch を停止してください。

example_code.rbの始めで、OpenSearch クライアントのインスタンス化をコメントアウトし、Elasticsearch クライアントのインスタンス化を追加しました。

ご覧のとおり、このテストシナリオではコードはほぼ同じです。これは、Elasticsearch のデプロイメントと、Elasticsearch との接続および認証の方法によって異なります。セキュリティに関しては OpenSearch と同じことが当てはまります。SSL を検証しないオプションはテスト目的のみであり、本番環境では使用しないでください。

クライアントがセットアップされたら、 bundle exec ruby example_code.rbを使用してコードを再度実行します。そして、すべてがうまく機能します!

移行問題のデバッグ

アプリケーションが使用している API によっては、OpenSearch の API が異なる場合、Elasticsearch に対してコードを実行するとエラーが発生する可能性があります。REST API ドキュメントは、API の使用方法に関する詳細な情報を得るための重要なリファレンスです。使用している Elasticsearch のバージョンのドキュメントを必ず確認してください。Elasticsearch::API参照も参照できます。

Elasticsearch で発生する可能性のあるエラーには次のようなものがあります:

ArgumentError: Required argument '<ARGUMENT>' missing - これはクライアントエラーであり、リクエストに必要なパラメータがない場合に発生します。
Elastic::Transport::Transport::Errors::BadRequest: [400] {"error":{"root_cause":[{"type":"illegal_argument_exception","reason":"request [/example/_doc] contains unrecognized parameter: [test]"}]... このエラーは Elasticsearch から発生し、クライアントコードが、使用されている API に対して Elasticsearch が認識しないパラメータを使用していることを意味します。

Elasticsearch クライアントは、サーバーから送信された詳細なエラーメッセージとともに、Elasticsearch からのエラーを発生させます。したがって、サポートされていないパラメータやエンドポイントの場合でも、エラーによって何が異なっているかが通知されるはずです。

まとめ

このサンプルコードで示したように、Ruby アプリを OpenSearch から Elasticsearch に移行することは、Ruby 側から見るとそれほど複雑ではありません。バージョン管理と、検索エンジン間で異なる可能性のある API に注意する必要があります。しかし、最も一般的なアクションでは、クライアントを移行する際の主な変更はインスタンス化にあります。その点ではどちらも似ていますが、ホストと資格情報の定義方法は、スタックの展開方法によって異なります。クライアントがセットアップされ、Elasticsearch に接続していることを確認したら、OpenSearch クライアントを Elasticsearch クライアントにシームレスに置き換えることができます。

問題を報告する