Elasticsearch --- 向es中導入數據

一.從文件導入(用django啟動)

def zi_dr(request):
    f = open('c.txt', 'r', encoding='utf-8')

    action = [
        {
            "_index": "c12",
            "_type": "doc",
            "_source": {
                "title": i.strip(),    #   去掉 空

            }
        } for i in f]

    s = time.time()
    helpers.bulk(es, action)
    print(time.time() - s)

    return HttpResponse("ok")

 

二. 從數據庫中導入(用django啟動)

def es2(request):

　　query_obj = models.Article.objects.all()

    action = (
        {
            "_index": "s18",
            "_type": "doc",
            "_source": {
                "title": i.title,
                "summary": i.summary,
                "a_url": i.a_url,
                "img_url": i.img_url,
                "tags": i.tags

            }
        } for i in query_obj)
    # print(action, next(action))
    import time
    s = time.time()

    helpers.bulk(es, action)
    print(time.time() - s)

    return HttpResponse('OK')