AMPQ (RabbitMQ) -> Postgres?

(В продолжение темы http://www.sql.ru/forum/1131228/demon-dlya-vypolneniya-proizvolnyh-vneshnih-komand-iz-bd )

Есть расширение pg_ampq для отправки сообщений в сервер очередей типа RabbitMQ.

А есть что-то такое же, но для приёма этих сообщений в postgres? То, что называется "consumer" в их терминологии.

Гугл молчит, но, думаю, это из-за того что я ключевые слова не знаю.

Weed,

>Есть расширение pg_ampq для отправки сообщений в сервер очередей типа RabbitMQ

это всё попытки скрестить перпендикулярные вещи.
база -- это не сеть.

--

для pgq есть подходы к упрвалению очередьми (сплит, федерализация, каскады)

http://skytools.projects.pgfoundry.org/skytools-3.0/doc/queue_mover3.html
http://skytools.projects.pgfoundry.org/skytools-3.0/doc/queue_splitter3.html

и есть "хендлеры" в лондайсте, например (http://skytools.projects.pgfoundry.org/skytools-3.0/doc/skytools3.html -- New features in Skytools 3 -- Londiste processes events via handlers), ну и можно самим эти консумеры писать и хенделры и на питоне (и даже на пхп) и на чем угодно, sql апи позволяет творить разные штуки: наследутейсь от нужного коснсумера и вперёд.

чего нету, так это, например, "отложенные задания". типа "отправь письмо через 20 минут". такое в раббите делается через "протухание" по ттл https://www.cloudamqp.com/docs/delayed-messages.html (http://www.rabbitmq.com/ttl.html и http://www.rabbitmq.com/dlx.html)

вы можете из пгку зачитать и отправить в буфер -- так делать отложенную отправку. если она нужна. // но придельные размеры буфера надо в любом случае контрлировать (хоть в раббите хоть где), и я бы буфер делал на чем-то прозрачном и понятно восстановимом.

Misha Tyurin,

автор
это всё попытки скрестить перпендикулярные вещи.

согласен. данный топик отменяется, в "обратную сторону" у нас уже есть интерфейс (я просто про него забыл)