用 python 操作 elasticsearch 使用的第三方库是 elasticsearch 。
1.python连接 elasticsearch 进行搜索
from elasticsearch import Elasticsearch
es = Elasticsearch([{'host': settings.ELASTICSEARCH_HOST, 'port': settings.ELASTICSEARCH_PORT}],timeout=3600) # 连接es
body = \
{
"query": {
"bool": {
"filter": {
"terms": {"type_id": [1, 3, 4, 5, 6]}
},
"must_not": {
"terms": {
"_id": must_not_list
}
}
,
"must": {
"range": {
"video_date": {
"gte": "now-24h+8h",
"lte": "now+8h"
}
}
}
}
},
"sort": {"video_like": {"order": "desc"}},
"from": start,
"size": size
}
data = es.search(body=body, index=settings.ELASTICSEARCH_INDEX)
2. python 连接 elasticsearch 增加文档
es = Elasticsearch([{'host': settings.ELASTICSEARCH_HOST, 'port': settings.ELASTICSEARCH_PORT}],
timeout=3600)
action = {
"type_id": now_ameme_data.get("type_id"),
"video_comment": now_ameme_data.get("video_comment"),
"share_count": now_ameme_data.get("share_count"),
"video_url": now_ameme_data.get("video_url"),
"category_id": now_ameme_data.get("category_id"),
"video_title": now_ameme_data.get("video_title"),
"user_id": now_ameme_data.get("user_id"),
"price": now_ameme_data.get("price"),
"video_like": now_ameme_data.get("video_like"),
"video_date": now_ameme_data.get("video_date"),
"updata_time": now_ameme_data.get("update_time"),
"video_img_url": now_ameme_data.get("video_img_url"),
"label": label
}
es.index(index="aweme_smart", body=action, id=aweme_id)
新增文档使用的是 index 方法,也可以为文档指定 id。action 里面的字段要和 es 文档的字段对应上。