|
|
@ -127,13 +127,9 @@ async def store_batch(data):
|
|
|
|
else:
|
|
|
|
else:
|
|
|
|
indexmap[INDEX].append(msg)
|
|
|
|
indexmap[INDEX].append(msg)
|
|
|
|
|
|
|
|
|
|
|
|
print("KEYS", indexmap.keys())
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
for index, index_messages in indexmap.items():
|
|
|
|
for index, index_messages in indexmap.items():
|
|
|
|
for message in index_messages:
|
|
|
|
for message in index_messages:
|
|
|
|
result = await client.index(index=index, body=message)
|
|
|
|
result = await client.index(index=index, body=message)
|
|
|
|
if index == "internal":
|
|
|
|
|
|
|
|
print("INTERNAL RES", result)
|
|
|
|
|
|
|
|
if not result["result"] == "created":
|
|
|
|
if not result["result"] == "created":
|
|
|
|
log.error(f"Indexing failed: {result}")
|
|
|
|
log.error(f"Indexing failed: {result}")
|
|
|
|
log.debug(f"Indexed {len(data)} messages in ES")
|
|
|
|
log.debug(f"Indexed {len(data)} messages in ES")
|
|
|
|