#python #mongodb #postgresql #azure
Вопрос:
Как я могу эффективно передавать вновь поступившие документы из Azure CosmosDB с помощью api MongoDB в Postgres через регулярные промежутки времени?
Я подумываю об использовании скрипта python для запроса MongoDB на основе даты, но я открыт для других предложений.
Комментарии:
1. Этот вопрос может потребовать большего внимания: похоже, вы уже решили использовать периодически запускаемый скрипт Python для выполнения переноса. Если это так, то сосредоточьтесь на вопросе подробнее: все, что вам нужно знать, — это как запрашивать MongoDB для документов, в которых поле содержит метку времени в заданном диапазоне. (Это не вопрос Azure или Postgresql.) ОТО, если вы еще не определились со своей архитектурой, просто спросите, как эффективно перенести недавно поступившие документы из AzureCosmosDB в Postgres.
2. Спасибо, я обновил свой вопрос.
Ответ №1:
Для этого вы можете использовать фабрику данных Azure. Используйте API MongoDB Azure Cosmos DB в качестве источника и Postgres в качестве приемника. Затем используйте водяной знак, чтобы записать время последнего изменения. Наконец, создайте триггер расписания для его выполнения.