|
|
|
AMPQ (RabbitMQ) -> Postgres?
|
|||
|---|---|---|---|
|
#18+
(В продолжение темы http://www.sql.ru/forum/1131228/demon-dlya-vypolneniya-proizvolnyh-vneshnih-komand-iz-bd ) Есть расширение pg_ampq для отправки сообщений в сервер очередей типа RabbitMQ. А есть что-то такое же, но для приёма этих сообщений в postgres? То, что называется "consumer" в их терминологии. Гугл молчит, но, думаю, это из-за того что я ключевые слова не знаю. ... |
|||
|
:
Нравится:
Не нравится:
|
|||
| 09.12.2014, 23:49:41 |
|
||
|
AMPQ (RabbitMQ) -> Postgres?
|
|||
|---|---|---|---|
|
#18+
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) вы можете из пгку зачитать и отправить в буфер -- так делать отложенную отправку. если она нужна. // но придельные размеры буфера надо в любом случае контрлировать (хоть в раббите хоть где), и я бы буфер делал на чем-то прозрачном и понятно восстановимом. ... |
|||
|
:
Нравится:
Не нравится:
|
|||
| 10.12.2014, 13:09:50 |
|
||
|
|

start [/forum/topic.php?fid=53&msg=38830094&tid=1998297]: |
0ms |
get settings: |
8ms |
get forum list: |
13ms |
check forum access: |
2ms |
check topic access: |
2ms |
track hit: |
28ms |
get topic data: |
8ms |
get forum data: |
2ms |
get page messages: |
45ms |
get tp. blocked users: |
1ms |
| others: | 242ms |
| total: | 351ms |

| 0 / 0 |
