2017-08-09 16 views
0

golangelasticパッケージを使用しています。大量の文書をバックグラウンドで送信するためにそのBulkProcessorを使用したいと思います。 wikiに示されているように、私はプロセッサを作ることができました。しかし、私は文書を送るたびにそれを作成したくありません。私は接続にプロセッササービスが存在し、新しいものを作成するのではなく既存のプロセッサにデータを渡すかどうかを知りたい。どうすれば達成できますか?ElasticSearch BulkProcessorサービスが存在するかどうかを確認する方法

答えて

0

バルクプロセッサをドキュメントとは別に登録してください。バルクプロセッサーはプロセスと同じ長さしかありませんので、一度だけ作成するために、プロセスの開始時に作成してください。アプリケーションの他の場所では、必要なときにドキュメントを送信できます。

また、オンデマンドで行う必要がある場合は、sync.Onceを使用して、作成が一度しか行われないようにすることができます。

関連する問題