aw_search.py

#! usr/local/bin/python3.6
# coding: utf-8

from elasticsearch.helpers import bulk
from elasticsearch import Elasticsearch
from . import models
from elasticsearch_dsl.connections import connections
from elasticsearch_dsl import DocType, Text, Date, Search

connections.create_connection()


class EntryIndex(DocType):
    title = Text()
    chron_date = Date()
    content = Text()
    category = Text()
    tag = Text()

    class Meta:
        index = 'ktab'


def bulk_indexing():
    EntryIndex.init()
    es = Elasticsearch()
    bulk(client=es, actions=(b.indexing() for b in
         models.Entry.objects.all().iterator()))