python-mysqlからelasticsearchにデータをエクスポート

2437 ワード

しばらくブログを更新していませんでしたが、最近面倒なことが多すぎて、学生党の私として、実習を要求して、半月以上もコードをちゃんとコードしていないのは、本当に罪ですね.最近会社は1つの対話システムをさせて、本当に私の頭がくらくらして頭がくらくらして、今日やっと1部の様子がないデータを手に入れて、データが本当に頭が大きいことを見て、幸いにも小編の基礎は少しあって、上司はExcelのデータを分けて、ちょうどExcelのデータをmysqlデータベースの中に導入することだと思って、しかし導入した後に、mysqlはelasticsearchに及ばないと感じて、それからまたmysqlの中からelasticsearchの中に導入して、800本のデータがあって、スピードはあまり速くなくて、みんなが小さい編にスピードを速める提案をあげることができることを望んで、ここで、私は私のコードを貼って、みんなが参考にして評論することができることを望んで、よし、背景の言う差は多くなくて、コードを貼りました:
# -*- 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の中に导入したことがあるかどうか分かりませんが、もしあるならば、小编に连络してください.结局「学海无涯苦作楽」ですか.小编に赏金をあげます...