ElasticSearch Sync Python Module

Admin tools for ElasticSearch sync.

pacifica.metadata.essync.create_worker_threads(threads, work_queue)

Create the worker threads and return the list.


Create the elastic search index and mappings.


Sync the elastic search data from sql to es.

pacifica.metadata.essync.generate_work(objects, items_per_page, work_queue, time_ago)

Generate the work from the db and send it to the work queue.


The main thread for the work.

pacifica.metadata.essync.try_doing_work(es_client, job)

Try doing some work even if you fail.

pacifica.metadata.essync.yield_data(obj, page_number, items_per_page, time_ago)

yield objects from obj for bulk ingest.