问题标签 [python-pika]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
81 问题
0
投票
0
回答
16
浏览
python - 我们可以使用 pika 通过 rabbitmq 添加自定义侦听器线程来消费消息吗？
我想使用自定义侦听器线程通过从服务器获取的 rabbitmq 队列来消费消息。我的情况是有 100 条消息在队列中，我想在应用程序启动时以快速有效的方式使用这些消息。
我创建了一个可以从 main 方法调用的连接。
我创建了消费消息的consume_message 函数，并且我正在使用一个应用程序来消费消息。
我们可以在这里执行 ThreadPoolExecutor 来提交消息吗？如果可以，我们该怎么做？
我们正在使用这个属性channel.basic_qos(prefetch_count=1)，如果我们使用 ThreadPoolExecutor 有什么用？