Elasticsearch-py中与别名操作相当的是什么?

20

我正在尝试使用 多索引 方法,使用 elasticsearch-dsl 实现。基本上有两个步骤:

1. 创建别名:

PUT /tweets_1/_alias/tweets_search 
PUT /tweets_1/_alias/tweets_index 

2. 必要时更改别名:

POST /_aliases
{
  "actions": [
    { "add":    { "index": "tweets_2", "alias": "tweets_search" }}, 
    { "remove": { "index": "tweets_1", "alias": "tweets_index"  }}, 
    { "add":    { "index": "tweets_2", "alias": "tweets_index"  }}  
  ]
}

我只能使用elasticsearch-py(而不是dsl)来实现步骤1:


from elasticsearch.client import IndicesClient
IndicesClient(client).("tweets_1", "tweets_search")
IndicesClient(client).("tweets_1", "tweets_index")

我不知道如何完成第二步,那么在elasticsearch-dsl中(或至少在elasticsearch-py中)相当于什么呢?

2个回答

30

要实现这一点,您需要使用elasticsearch-py

from elasticsearch import Elasticsearch
es = Elasticsearch()

# use es.indices instead of instantiating IndicesClient
es.indices.put_alias(index='tweets_1', name='tweets_search')
es.indices.put_alias(index='tweets_1', name='tweets_index')

es.indices.update_aliases({
  "actions": [
    { "add":    { "index": "tweets_2", "alias": "tweets_search" }}, 
    { "remove": { "index": "tweets_1", "alias": "tweets_index"  }}, 
    { "add":    { "index": "tweets_2", "alias": "tweets_index"  }}  
  ]
})

更新别名不再接受“actions”吗?这个回应很有道理,但是却没有起作用。 - j7skov
你确定你在使用版本8吗?在8.11 python api的actions中,但在v7中是body,尽管网络api在这方面没有改变。 - undefined

0
index_list_for_realias = [...]
aliases_list_to_realias = [...]

for i in index_list_for_realias:
    print(i)
    for j in aliases_list_to_realias:
        es.indices.put_alias(index=i, name="logstash5-uni-" + j, body={
                "filter": {
                    "term": {
                        "uni": j
                    }
                }
            }
        )

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接