Elasticsearch DSL update by scan？

Question

可以使用Python的elasticsearch-dsl库中的scan()方法进行更新吗？

例如：

search = Search(index=INDEX).query(query).params(request_timeout=6000)

print('Scanning Query and updating.')
for hit in search.scan():
    _id = hit.meta.id
    # sql query to get the record from th database
    record = get_record_by_id(_id)
    hit.column1 = record['column1']
    hit.column2 = record['column2']
    # not sure what use to update here

Answer 1

这可以通过使用elasticsearch客户端来完成：

for hit in search.scan():
    _id = hit.meta.id
    print(_id)

    # get data from database
    record = get_record_by_id(_id)

    body = dict(record)
    body.pop('_id')

    # update the elastichsearch client
    elastic_client.update(
        index=INDEX,
        id=_id,
        body={"doc": body}
    )