python操作elasticsearch
阿新 • • 發佈:2022-04-22
import time import elasticsearch.helpers from faker import Faker from elasticsearch import Elasticsearch f = Faker(locale='zh_CN') es = Elasticsearch("http://ip:port") start_time = time.time() def re_list(start: int, setup: int, header=False): l = [{ '_op_type': 'index', '_index': "user_info", # index "_source": { "ID": i + start * setup, "Name": f.name(), "Address": f.address(), "Ssn": f.ssn(), "Company": f.company(), "Job": f.job(), "Email": f.email(), "Url": f.domain_name(), "Card": f.credit_card_number(), "PhoneNumber": f.phone_number(), "UserName": f.user_name(), "Password": f.password(), "HeadImg": f.image_url(), } } for i in range(0, setup)] # print(l) # 插入多條資料 elasticsearch.helpers.bulk(es, l) # 插入一條資料 # document = {'ID': 0, 'Name': '張芳', 'Address': '吉林省雷市錫山潘街H座 777298', 'Ssn': '350524196101092684', # 'Company': '暉來計算機傳媒有限公司', 'Job': '技術總監/經理', 'Email': '[email protected]', 'Url': 'xiaozhu.cn', # 'Card': '378592230159964', 'PhoneNumber': '13927464009', 'UserName': 'mpan', 'Password': '$@_4FJ7vf0', # 'HeadImg': 'https://placeimg.com/839/937/any'} # es.index(index="user_info", document=document) # 查詢資料 # resp = es.search(index="user_info", query={"multi_match": {"query": "777298"}}) # resp = es.search(index="user_info", query={"match_all": {}}) # for hit in resp["hits"]["hits"]: # if hit: # print(hit["_source"]) if __name__ == '__main__': for i in range(0, 1): re_list(i, 1)