从别人的es数据拉去到另一台机器python如何写
时间: 2023-05-17 13:04:39 浏览: 49
你可以使用Python的elasticsearch模块来连接到Elasticsearch集群,并使用scroll API来检索所有文档。然后,你可以将数据保存到本地文件或将其发送到另一台机器。以下是一个示例代码:
```python
from elasticsearch import Elasticsearch
# 连接到Elasticsearch集群
es = Elasticsearch(['http://localhost:9200'])
# 搜索所有文档
scroll = '2m'
size = 1000
body = {
"query": {
"match_all": {}
}
}
search_result = es.search(
index='my_index',
scroll=scroll,
size=size,
body=body
)
# 检索所有文档
scroll_id = search_result['_scroll_id']
hits = search_result['hits']['hits']
while hits:
# 处理当前批次的文档
for hit in hits:
# 处理文档
pass
# 检索下一批文档
search_result = es.scroll(scroll_id=scroll_id, scroll=scroll)
scroll_id = search_result['_scroll_id']
hits = search_result['hits']['hits']
```
在处理完所有文档后,你可以将数据保存到本地文件或将其发送到另一台机器。