|
|
|
|
@ -50,7 +50,7 @@ async def store_kafka_batch(data):
|
|
|
|
|
batch = producer.create_batch()
|
|
|
|
|
for msg in data:
|
|
|
|
|
if msg["type"] in TYPES_MAIN:
|
|
|
|
|
#index = "main"
|
|
|
|
|
# index = "main"
|
|
|
|
|
index = MAIN_SRC_MAP[msg["src"]]
|
|
|
|
|
# schema = mc_s.schema_main
|
|
|
|
|
elif msg["type"] in TYPES_META:
|
|
|
|
|
|
