Elasticsearch --- 向es中导入数据

Posted sc-1067178406

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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)

 

以上是关于Elasticsearch --- 向es中导入数据的主要内容,如果未能解决你的问题,请参考以下文章

向elasticsearch中动态添加字段报错问题和向elasticsearch中添加嵌套数据类型数据--工作学习记录

elasticsearch使用es-head在已有索引中新增字段以及更新记录

亿级高并发电商项目-- 实战篇 --万达商城项目 十(安装与配置Elasticsearch和kibana编写搜索功能向ES同步数据库商品数据)

亿级高并发电商项目-- 实战篇 --万达商城项目 十(安装与配置Elasticsearch和kibana编写搜索功能向ES同步数据库商品数据)

亿级高并发电商项目-- 实战篇 --万达商城项目 十(安装与配置Elasticsearch和kibana编写搜索功能向ES同步数据库商品数据)

FileBeat向elasticsearch传入数据,并使用GROK处理