使用RabbitMQ和Plone - 芹菜与否？

首先,问问自己,如果你需要RabbitMQ的功能,或者只是想用Plone在Python中做一些异步任务.

如果你真的不需要RabbitMQ,你可以查看David Glick关于如何将Celery与Plone集成(以及仍然使用RabbitMQ和Celery)的要点:

https://gist.github.com/davisagli/5824662

https://gist.github.com/davisagli/5824709

您还可以查看collective.taskqueue(没有Celery和RabbitMQ的简单队列),但它还没有提供任何监控解决方案.

如果你真的需要RabbitMQ,请跳过Celery,然后尝试使用collective.zamqp.Celery本身试图成为经纪人,并且会阻止您使用AMQP和RabbitMQ的大部分内置功能.

RabbitMQ附带了很棒的Web管理插件用于监控,还有第三方监控系统的插件(如Zenoss).

很抱歉,collective.zamqp仍然缺少叙述性文档,但您可以查看collective.zamqpdemo以获取其配置和用法的各种示例.

简而言之,c.zamqp允许您根据生产者和使用者定义配置代理使用情况:

from five import grok
from zope.interface import Interface
from collective.zamqp.producer import Producer
from collective.zamqp.consumer import Consumer


class CreateItemProducer(Producer):
    """Produces item creation requests"""
    grok.name("amqpdemo.create")  # is also used as default routing key

    connection_id = "superuser"
    serializer = "msgpack"
    queue = "amqpdemo.create"

    durable = False


class ICreateItemMessage(Interface):
    """Marker interface for item creation message"""


class CreateItemConsumer(Consumer):
    """Consumes item creation messages"""
    grok.name("amqpdemo.create")  # is also used as the queue name

    connection_id = "superuser"
    marker = ICreateItemMessage

    durable = False

    import uuid

    from zope.component import getUtility
    from collective.zamqp.interfaces import IProducer

    producer = getUtility(IProducer, name="amqpdemo.create")
    producer._register()  # register to bound to successful transaction

    message = {"title": u"My title"}

    producer.publish(message)

from zope.component.hooks import getSite
from collective.zamqp.interfaces import IMessageArrivedEvent
from plone.dexterity.utils import createContentInContainer

@grok.subscribe(ICreateItemMessage, IMessageArrivedEvent)
def createItem(message, event):
    """Consume item creation message"""

    portal = getSite()
    obj = createContentInContainer(
        portal, "Document", checkConstraints=True, **message.body)

    message.ack()

[instance]
recipe = plone.recipe.zope2instance
...
zope-conf-additional =
    %import collective.zamqp
    <amqp-broker-connection>
         connection_id superuser
         heartbeat 120
# These are defaults, but can be defined when required:     
#        hostname localhost
#        virtual_host /
#        username guest
#        password guest
    </amqp-broker-connection>
    <amqp-consuming-server>
        connection_id superuser
        site_id Plone
        user_id admin
        vhm_method_prefix /VirtualHostBase/https/example.com:443/Plone/VirtualHostRoot
    </amqp-consuming-server>