Cloudant слушатель базы данных в python

Question

Я пытаюсь создать слушатель в Python, который автоматически извлекает изменения в базе данных Cloudant по мере их возникновения. Когда происходит изменение, я хочу вызвать определенную функцию.

Я прочитал документацию и спецификации API, но ничего не смог найти.

Есть ли способ сделать это?

Answer 1

Вот базовая программа чтения потоковых изменений (отказ от ответственности: я ее написал):

https://github.com/xpqz/pylon/blob/master/pylon.py

Официальная клиентская библиотека Cloudant Python также содержит подписчик изменений:

https://python-cloudant.readthedocs.io/en/latest/feed.html

Получить читателя базовых изменений достаточно просто, так как _changes конечная точка с feed=continuous Параметр довольно много делает для вас, включая передачу результатов обратно в виде отдельных json-объектов на строку. Трудно иметь дело с совершенно неочевидным набором условий отказа.