在Elasticsearch中,默认情况下,打开滚动的最大数量是500,但我需要增加这个数字。在本地机器上更新"search.max_open_scroll_context“没有问题,但AWS Elasticsearch不允许进行更改。 在尝试使用这个线程configure-search-max-open-scroll-context中给出的答案进行更新时,得到的响应是:{"Message":"Your request: '/_cluster/settings' payload is not allowed."},而我可以在本地Elas
我们在Elastic Cloud上托管elatsicsearch集群,并从数据流(GCP)调用它。作业在dev中运行良好,但是当我们部署到prod时,我们在客户端看到了大量的连接超时。
Traceback (most recent call last):
File "apache_beam/runners/common.py", line 1213, in apache_beam.runners.common.DoFnRunner.process
File "apache_beam/runners/common.py", line 570, in apa
我已经安装了elasticsearch python软件包,并创建了一个弹性集群。我使用下面的python代码将数据发送到弹性云:
from elasticsearch import Elasticsearch, RequestsHttpConnection
import time
import datetime
es = Elasticsearch(['70.19.172.110:9200'],http_auth=('<username>','<password>'))
for x in range(0,5):
我有一个弹性搜索的索引,里面有大量的数据。我试图在python中加载它的一些数据(超过10000条记录)以供进一步处理。根据文档和网络搜索,使用了滚动,但是它只能获取很少的记录。当这个异常发生的时候,
errorNotFoundError(404, 'search_phase_execution_exception', 'No search context found for id [101781]')
我的代码如下:
from elasticsearch import Elasticsearch
##########elastic configuratio
我对Elasticsearch的滚动功能感到有点困惑。在elasticsearch中,每当用户在结果集中滚动时,是否可以每次调用search?从文件
"search_type" => "scan", // use search_type=scan
"scroll" => "30s", // how long between scroll requests. should be small!
"size" => 50, // how many re
我想通过Elasticsearch DSL for Python使用query_string (Lucene Syntax)搜索。不幸的是,第一行并不像第二行那么简单: s = Search(using=client, index='abc').query("query_string", doctext=searchstr).highlight('doctext', fragment_size=200) s = Search(using=client, index='abc').query("match", do
考虑以下示例:
NUMBER_KEYWORDS = 3000
es = Elasticsearch("127.0.0.1",port=9200,timeout=120,index="example_index",http_auth=AUTH)
query = {'query': {"bool": { "should": [{"match": {"value.keyword": v}} for v in ["keyword" for i in range(NUMBER_
我使用python2.7和Elasticsearch-DSL包来查询我的弹性集群。
尝试向查询添加"from“和”limit“功能,以便在呈现文档弹性返回的FE中进行分页,但”from“不能正常工作(即我没有正确使用它。)
相关代码为:
s = Search(using=elastic_conn, index='my_index'). \
filter("terms", organization_id=org_list)
hits = s[my_from:my_size].execute() # if from = 10, siz
我正在运行logstash 1.4.1,在运行它的时候,我在控制台上得到了如下结果:
failed to open /home/Desktop/Input/2014-11-03/abc.log: Permission denied - /home/Desktop/Input/2014-11-03/abc.log {:level=>:warn}
failed to open /home/Desktop/Input/2014-10-14/abc.log: Permission denied - /home/Desktop/Input/2014-10-14/abc.log {:
我使用的是python的elasticsearch dsl库。我在一个线程应用程序中运行滚动扫描,如下所示: s = Search\
.from_dict(query)\
.using(es)\
.index(index)\
.doc_type(doc_type)\
.extra(slice=slice)
for hit in s.scan():
yield hit 可以有32个线程全部运行在具有不同切片的同一滚动条上。有时,这会导致429 Too Many Requests错误,并终止整个过程。令人心碎的是,这可能会在滚动1小时后发生,这个
我一直在使用ElasticSearch DSL python包来查询我的elastic search数据库。查询方法非常直观,但是我在检索文档时遇到了问题。这是我尝试过的:
from elasticsearch import Elasticsearch
from elasticsearch_dsl import Search
es = Elasticsearch(hosts=[{"host":'xyz', "port":9200}],timeout=400)
s = Search(using=es,index ="xyz-*").