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.
-
pacifica.metadata.essync.
escreate
(args)¶ Create the elastic search index and mappings.
-
pacifica.metadata.essync.
essync
(args)¶ 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.
-
pacifica.metadata.essync.
start_work
(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.