Слушатель базы данных Cloudant на Python
Я пытаюсь создать прослушиватель в python, который автоматически извлекает изменения в базе данных Cloudant по мере их появления. Когда происходит изменение, я хочу вызвать определенную функцию.
Я прочитал документацию и спецификации API, но ничего не нашел.
Есть ли способ сделать это?
Ответы 1
Вот базовая программа для чтения каналов изменений потоковой передачи (отказ от ответственности: я ее написал):
https://github.com/xpqz/pylon/blob/master/pylon.py#L165
Официальная клиентская библиотека Cloudant Python также содержит подписчик ленты изменений:
https://python-cloudant.readthedocs.io/en/latest/feed.html
Довольно легко запустить программу чтения каналов базовых изменений, поскольку конечная точка _changes с параметром feed=continuous делает для вас довольно много, включая передачу результатов обратно в виде автономных json-объектов на строку. Жесткий бит имеет дело с довольно неочевидным набором условий отказа.
Спасибо за ответ! Мне удалось получить слушателя, используя клиентскую библиотеку python и cloudant.feed.Feed. Однако я не могу запустить приложение фляги, пока код слушателя «слушает». Я думаю, проблема в том, что он перебирает изменения и «застревает» в цикле for. Вы знаете какое-нибудь решение?