当我尝试使用pika(python)确认对RabbitMQ的确认消息时，发生错误“未知的传递标签” - python

我希望在几个线程中处理消息，但是在执行此代码期间出现错误:

from __future__ import with_statement
import pika
import sys
from pika.adapters.blocking_connection import BlockingConnection
from pika import connection, credentials
import time
import threading
import random
from pika.adapters.select_connection import SelectConnection
from pika.connection import Connection
import traceback


def doWork(body, args, channel):


    r = random.random()
    time.sleep(r * 10)
    try:        
        channel.basic_ack(delivery_tag=args.delivery_tag)

    except :
        traceback.print_exc()


auth = credentials.PlainCredentials(username="guest", password="guest")
params = connection.ConnectionParameters(host="localhost", credentials=auth)
conn = BlockingConnection(params)
channel = conn.channel()


while True:

    time.sleep(0.03)    
    try:

        method_frame, header_frame, body = channel.basic_get(queue="test_queue")
        if method_frame.NAME == 'Basic.GetEmpty':
            continue        

        t = threading.Thread(target=doWork, args=[body, method_frame, channel])
        t.setDaemon(True)
        t.start()

    except Exception, e:
        traceback.print_exc()
        continue

错误说明:

追溯(最近一次通话):
在第43行的文件“C:\ work \ projects \ mq \ start.py”
method_frame，header_frame，body = channel.basic_get(queue =“test_queue”)
文件“C:\ work \ projects \ mq \ libs \ pika \ adapters \ blocking_connection.py”，第318行，位于basic_get中
self.basic_get_(self，self._on_basic_get，票证，队列，no_ack)
在basic_get中，文件“C:\ work \ projects \ mq \ libs \ pika \ channel.py”，第469行
no_ack = no_ack))
send_method中的第244行的文件“C:\ work \ projects \ mq \ libs \ pika \ adapters \ blocking_connection.py”
self.connection.process_data_events()
文件“C:\ work \ projects \ mq \ libs \ pika \ adapters \ blocking_connection.py”，行94，在process_data_events中
self._handle_read()
_handle_read中的文件“C:\ work \ projects \ mq \ libs \ pika \ adapters \ base_connection.py”，第162行
self._on_data_available(数据)
文件“C:\ work \ projects \ mq \ libs \ pika \ connection.py”，行589，在_on_data_available中
框架)＃Args
正在处理文件“C:\ work \ projects \ mq \ libs \ pika \ callback.py”，第124行
回调(* args，**关键字)
_on_remote_close中的文件“C:\ work \ projects \ mq \ libs \ pika \ adapters \ blocking_connection.py”，第269行
frame.method.reply_text)
AMQPChannelError:(406，'PRECONDITION_FAILED-未知交付标签204')

版本:pika 0.9.5，rabbitMQ 2.6.1

参考方案

问题可能是您正在这样设置no_ack=True:

consumer_tag = channel.basic_consume(
    message_delivery_event,
    no_ack=True,
    queue=queue,
)

然后确认消息:

channel.basic_ack(delivery_tag=args.delivery_tag)

您必须选择是否要确认并设置正确的消耗参数。

Python GPU资源利用 - python

我有一个Python脚本在某些深度学习模型上运行推理。有什么办法可以找出GPU资源的利用率水平？例如，使用着色器，float16乘法器等。我似乎在网上找不到太多有关这些GPU资源的文档。谢谢！ 参考方案 您可以尝试在像Renderdoc这样的GPU分析器中运行pyxthon应用程序。它将分析您的跑步情况。您将能够获得有关已使用资源，已用缓冲区，不同渲染状态上…

Python:图像处理可产生皱纹纸效果 - python

也许很难描述我的问题。我正在寻找Python中的算法，以在带有某些文本的白色图像上创建皱纹纸效果。我的第一个尝试是在带有文字的图像上添加一些真实的皱纹纸图像（具有透明度）。看起来不错，但副作用是文本没有真正起皱。所以我正在寻找更好的解决方案，有什么想法吗？谢谢 参考方案 除了使用透明性之外，假设您有两张相同尺寸的图像，一张在皱纹纸上明亮，一张在白色背景上有深…

Python uuid4，如何限制唯一字符的长度 - python

在Python中，我正在使用uuid4（）方法创建唯一的字符集。但是我找不到将其限制为10或8个字符的方法。有什么办法吗？uuid4()ffc69c1b-9d87-4c19-8dac-c09ca857e3fc谢谢。 参考方案 尝试：x = uuid4() str(x)[:8] 输出："ffc69c1b" Is there a way to…

Python sqlite3数据库已锁定 - python

我在Windows上使用Python 3和sqlite3。我正在开发一个使用数据库存储联系人的小型应用程序。我注意到，如果应用程序被强制关闭（通过错误或通过任务管理器结束），则会收到sqlite3错误（sqlite3.OperationalError：数据库已锁定）。我想这是因为在应用程序关闭之前，我没有正确关闭数据库连接。我已经试过了： connectio…

Python:如何停止多线程的numpy？ - python

我知道这似乎是一个荒谬的问题，但是我必须在与部门中其他人共享的计算服务器上定期运行作业，当我开始10个作业时，我真的希望它只占用10个核心而不是更多;我不在乎每次运行一个内核所需的时间是否更长:我只是不想让它侵犯其他人的领土，这将需要我放弃工作等等。我只想拥有10个核心，仅此而已。更具体地说，我在基于Python 2.7.3和numpy 1.6.1的Redh…