Python连接es笔记之创建和删除操作示例详解

from elasticsearch_dsl import connections
connections.configure(
    default={"hosts": "localhost:9200"},
)
conn = connections.connections.get_connection("default")

index_name = "test_create"
conn.indices.create(index_name)

print(conn.indices.exists(index_name))

conn.indices.delete(index_name)

index_name = "test_create"
conn.index(
    index=index_name,
    id=1,
    body={
        "name": "李白"
    }
)

conn.index(
    index=index_name,
    body={
        "name": "李白"
    }
)

action_1 = {
    "_op_type": "index",
    "_index": "test_create",
    "doc": {"age": 20, "name": "杨过", "address": "终南山"},
}
action_2 = {
    "_op_type": "index",
    "_index": "test_create",
    "doc": {"age": 21, "name": "郭靖", "address": "桃花岛"},
}
action_list = [action_1, action_2]
helpers.bulk(conn, actions=action_list)

s = Search(using="default").index("exam").query("match", name="张三丰")
s.delete()

conn = connections.connections.get_connection("default")
q1 = ES_Q("term", name="杨过")
conn.delete_by_query(
    index="exam",
    body={
        "query": q1
    }
)