小编Ada*_*ing的帖子

我对AMQP的理解是消息只有以下组件:

1. 消息体
2. 路由密钥
3. 找的零钱

队列附加到交易所.消息不能具有任何队列知识.它们只是发布到交换机,然后根据交换类型和路由密钥,消息被路由到一个或多个队列.

在Celery中,推荐的路由任务方法是通过CELERY_ROUTES设置.来自文档,CELERY_ROUTES是......

路由器列表,或用于将任务路由到队列的单个路由器. http://celery.readthedocs.org/en/latest/configuration.html#message-routing

它包括一个例子......

要将任务路由到feed_tasks队列,可以在CELERY_ROUTES设置中添加条目 :

CELERY_ROUTES = {
    'feeds.tasks.import_feed': {
        'queue': 'feed_tasks',
        'routing_key': 'feed.import',
    },
}

Run Code Online (Sandbox Code Playgroud)

但是等一下 - 根据AMQP,消息只带有路由密钥!什么是"排队"在那里做什么？

此外,还有一个默认队列的概念.如果您调用未被捕获的任务CELERY_ROUTES,则会回退到CELERY_DEFAULT_QUEUE.但是再次 - 在AMQP中,消息不知道队列.这不应该是默认的路由密钥吗？

很少,Django消息在HTML响应中呈现.然后,用户GET是另一个页面,再次呈现Django消息.有时,用户GET此后将显示另一页,并且将再次显示相同的消息.

这很少发生,但是当它发生时,大多数用户会在一段时间内看到相同的行为.(它发生在一组跨浏览器测试中,并且在离开之前,房间里的每个人在他们的每台计算机上看到相同的行为大约五分钟.)

许多不同的视图都出现了这种情况; 此外,每个视图以相同的方式添加它们(见下文).

我无法在部署环境(运行wsgi.py)或在本地环境(运行manage.py)上运行项目时可靠地重现错误.(我会注意到我从未在本地见过这个问题.)

有谁知道为什么会发生这种情况？

添加成功消息的示例.

       messages.success(
            request,
            "Changes to {form} {request} were successfully saved."\
            .format(form=self.form.display_name,
                    request=serv_request_id_as_url(self.serv_request))
        )

这是呈现消息的模板代码:

<div id="messages">
  {% for message in messages %}
    <div class="alert alert-{{ message.tags }}">
      <a class="close" data-dismiss="alert" href="#" title="Close"><span class="accessibility">Close this message.</span>&times;</a>
      <strong>{{ message.message|safe }}</strong>
    </div>
  {% endfor %}
</div>

相关设置:

MIDDLEWARE_CLASSES = (
    'django.middleware.gzip.GZipMiddleware',
    'django.middleware.common.CommonMiddleware',
    'outage.middleware.OutageMiddleware',
    'django.contrib.sessions.middleware.SessionMiddleware',
    'django.middleware.transaction.TransactionMiddleware',
    'django.middleware.csrf.CsrfViewMiddleware',
    'django.middleware.clickjacking.XFrameOptionsMiddleware',
    'utdirect.middleware.HttpHeaderMiddleware',
    'django.contrib.auth.middleware.AuthenticationMiddleware',
    'django.contrib.messages.middleware.MessageMiddleware', ... )

MESSAGE_STORAGE = 'django.contrib.messages.storage.session.SessionStorage' …

我想我可能会误解finallytry/ except/finally 块的子句在 Python 中对于生成器的工作原理。

在下面的代码块中，生成器启动一个线程，如果调用者因任何原因退出，则该线程将被清理。至少这是意图。

但是，我注意到在一些奇怪的情况下，该finally块不会运行：如果调用者引发然后捕获自己的异常，并将异常对象分配给变量，则finally不会运行。我不知道为什么会这样。

这是代码。

import signal
from threading import Thread
import time


class MyThread(Thread):
    def __init__(self):
        super().__init__()
        self._stopped = False
    def run(self):
        while not self._stopped:
            time.sleep(0.2)
    def stop(self):
        self._stopped = True


class ThreadRunner:
    def start(self):
        self._my_thread = MyThread()
        self._my_thread.start()
    def end(self):
        self._my_thread.stop()
        self._my_thread.join()
        print('ThreadRunner end!')


def loop_forever():
    thread_runner = ThreadRunner()
    try:
        thread_runner.start()
        yield
    finally:
        print('loop_forever() is all done!')  # When does this line get run?
        thread_runner.end()


def listener():
    print('listener begin!')
    looper = …