python-mysqlからelasticsearchにデータをエクスポート
2437 ワード
しばらくブログを更新していませんでしたが、最近面倒なことが多すぎて、学生党の私として、実習を要求して、半月以上もコードをちゃんとコードしていないのは、本当に罪ですね.最近会社は1つの対話システムをさせて、本当に私の頭がくらくらして頭がくらくらして、今日やっと1部の様子がないデータを手に入れて、データが本当に頭が大きいことを見て、幸いにも小編の基礎は少しあって、上司はExcelのデータを分けて、ちょうどExcelのデータをmysqlデータベースの中に導入することだと思って、しかし導入した後に、mysqlはelasticsearchに及ばないと感じて、それからまたmysqlの中からelasticsearchの中に導入して、800本のデータがあって、スピードはあまり速くなくて、みんなが小さい編にスピードを速める提案をあげることができることを望んで、ここで、私は私のコードを貼って、みんなが参考にして評論することができることを望んで、よし、背景の言う差は多くなくて、コードを貼りました:
みんなが直接Excelの中のデータをelasticsearchの中に导入したことがあるかどうか分かりませんが、もしあるならば、小编に连络してください.结局「学海无涯苦作楽」ですか.小编に赏金をあげます...
# -*- coding: utf-8 -*-
import pymysql
from elasticsearch import Elasticsearch
# (ip/ / / )
db = pymysql.connect("localhost", "root", "root", "gongan",charset='utf8')
# cursor() cursor
cursor = db.cursor()
sql = "SELECT * FROM sheet1"
es = Elasticsearch()
try:
# execute() SQL
cursor.execute(sql)
#
results = cursor.fetchall()
new = []
i = -1
for row in results:
i+=1
es.index(index='gongan', doc_type='test-type', body={
'id': i,
'question': row[0],
'question_one':row[1],
'answer':row[2]
})
except:
print("Error: unable to fecth data")
#
db.close()
みんなが直接Excelの中のデータをelasticsearchの中に导入したことがあるかどうか分かりませんが、もしあるならば、小编に连络してください.结局「学海无涯苦作楽」ですか.小编に赏金をあげます...