Запись данных MongoDB вasticsearch хорошо работает локально, но не в Google Cloud
Я пытаюсь прочитать данные MongoDB и записать вasticsearch и использовать Kibana для визуализации, и система развернута в Google Cloud.Код работал отлично в течение нескольких минут, и количество обращений в Kibana продолжало увеличиваться, тогда новые данные не поступали (число посещений не увеличивалось).Однако это хорошо работало на локальном компьютере.Любые предложения будут оценены.Спасибо!
cursor = mycollection.find({})
for msg in cursor:
count += 1
current_primary_key = int(str(msg['_id'])[-6:],16)
if current_primary_key > highest_previous_primary_key:
action = { ... }
es.create(index = "indexName", doc_type = "docType", id = count, body = action)
highest_previous_primary_key = current_primary_key