問題タブ [pyelasticsearch]

Elasticsearch でスクロールするときは、各スクロールで最新のものを提供することが重要scroll_idです。

最初の検索リクエストと後続の各スクロール リクエストは、新しい scroll_id を返します — 最新の scroll_id のみを使用する必要があります。

次の例 (ここから取得) は、私を困惑させます。まず、スクロールの初期化:

そしてループ：

それは機能しますが、どこが更新されているのかわかりませんsid... Pythonクライアントで内部的に発生すると思います。しかし、私はそれがどのように機能するのか理解していません...

したがって、* はelasticsearchクエリでエスケープする必要がある特殊文字であることを理解しているということで、これにプレフィックスを付ける必要があります。これが私が直面しているセットアップとトラブルです。基本的な問題は、'*' のみを含むフィールドを検索できないということです。

検索で最初に表示されるアイテムを取得するにはどうすればよいですか? さまざまな検索方法には矛盾がありますが、「*」を返すことは許可されていないことに全員が同意しているように見えますが、なぜでしょうか? また、 * をエスケープすると問題が悪化するようですが、これはちょっと珍しいことです。(おそらくライブラリには自動エスケープがあると思いますが、それは直接の ES クエリを実際には説明していません)。

編集：間違いなくインデックスが作成されていることに言及する必要があります。

保存されている可能性がありますが、私の知る限り、これはelasticsearchにとって特別なものですか?

Edit2: いくつかのエスケープについて話しているElasticSearchドキュメント

私はpy-elasticsearchバルク@Diolorソリューションが機能することについて混乱してい ます-pythonですが、プレーンな es.bulk() を使用したい

私のコード:

エラーは次のとおりです。

POST 呼び出し用に生成された URL は

/logstash-test/test/_bulk

POST 本文は次のとおりです。

{"host":"logsqa","path":"/logs","message":"test test","@timestamp":"2014-10-02T10:11:25.980256","tags":["複数行","mydate_0.005"]}

だから私は手でカールをしました：このカールはうまくいきません：

したがって、エラーは部分的に問題ありませんが、elasticsearch.bulk() が入力引数を適切に管理することを期待していました。

pythonf 関数は次のとおりです。

localhost 9200 で Elasticsearch サーバーを作成するスクリプトを Python で作成したいと思います。オンラインで見つけたすべての例は、localhost 9200 で実行されている既存の Elasticsearch インスタンスへの接続に関するものです。コマンドラインを使用して、サーバーを実行またはシャットダウンします。

基本的にこの行を置き換えます

Pythonの何かで。

更新：私は次のことを試しました

ただし、「AttributeError: 'module' オブジェクトに属性 'popen' がありません」というエラーが表示されます。

私の application.py ファイルは、elasticsearch サービスを実行してから、elasticsearch サーバーへの呼び出しに使用できる別のサービスを作成します。

プログラムでelasticsearchインスタンスを作成する方法のコードスニペットを提供してくれる人はいますか? これを行う既存のプロジェクトはありますか? 助けてくれてありがとう。