Update esIndexer.py
parent
cecb4ae764
commit
c0f7fb32d1
|
@ -58,7 +58,7 @@ class ESIndexer():
|
||||||
if self.client.indices.exists(index=self.ccr_index) is False:
|
if self.client.indices.exists(index=self.ccr_index) is False:
|
||||||
Renewal.init()
|
Renewal.init()
|
||||||
|
|
||||||
def indexRecords(self, recType='ccr'):
|
def indexRecords(self, recType='cce'):
|
||||||
"""Process the current batch of updating records. This utilizes the
|
"""Process the current batch of updating records. This utilizes the
|
||||||
elasticsearch-py bulk helper to import records in chunks of the
|
elasticsearch-py bulk helper to import records in chunks of the
|
||||||
provided size. If a record in the batch errors that is reported and
|
provided size. If a record in the batch errors that is reported and
|
||||||
|
|
Loading…
Reference in New Issue