如何通过Python高效生成并写入ES数据库的大量数据同时进行查询?
- 内容介绍
- 文章标签
- 相关推荐
本文共计2212个文字,预计阅读时间需要9分钟。
前言:模拟学生成绩信息写入ES数据库,包括姓名、性别、科目、成绩。示例代解码:
pythonfrom elasticsearch import Elasticsearch
创建ES连接实例es=Elasticsearch()
定义学生数据student_data=[ {name: 张三, gender: 男, subject: 数学, score: 90}, {name: 李四, gender: 女, subject: 语文, score: 85}, {name: 王五, gender: 男, subject: 英语, score: 88}]
批量写入数据es.bulk(index=students, actions=[{_index: students, _source: data} for data in student_data])
查询示例query={query: {match_all: {}}}results=es.search(index=students, body=query)
打印查询结果for result in results['hits']['hits']: print(result['_source'])
前言:
模拟学生成绩信息写入es数据库,包括姓名、性别、科目、成绩。
本文共计2212个文字,预计阅读时间需要9分钟。
前言:模拟学生成绩信息写入ES数据库,包括姓名、性别、科目、成绩。示例代解码:
pythonfrom elasticsearch import Elasticsearch
创建ES连接实例es=Elasticsearch()
定义学生数据student_data=[ {name: 张三, gender: 男, subject: 数学, score: 90}, {name: 李四, gender: 女, subject: 语文, score: 85}, {name: 王五, gender: 男, subject: 英语, score: 88}]
批量写入数据es.bulk(index=students, actions=[{_index: students, _source: data} for data in student_data])
查询示例query={query: {match_all: {}}}results=es.search(index=students, body=query)
打印查询结果for result in results['hits']['hits']: print(result['_source'])
前言:
模拟学生成绩信息写入es数据库,包括姓名、性别、科目、成绩。

