腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Rabbitmq
pika.BasicProperties
不
发送
消息
中
的
属性
python
、
rabbitmq
、
pika
我正在使用pika向
rabbitmq
发送
消息
。我需要
发送
额外
的
属性
,所以我使用了
pika.BasicProperties
,但是当我在Wireshark中看到这条
消息
时,并没有添加任何
属性
。我
的
代码: import pika, uuid pika.ConnectionParameters(host='localhostcha
浏览 40
提问于2021-01-07
得票数 0
回答已采纳
1
回答
如何将
消息
从Flask
发送
到
RabbitMQ
服务器队列?
python
、
rabbitmq
我试图从作为生产者
的
Flask服务器向
RabbitMQ
服务器队列
发送
一条
消息
。我用来产生
消息
的
端口是'5672‘。我已经在
RabbitMQ
的
Management服务器上创建了一个exchange和一个队列,主要目标是在服务器队列
中
接收一条
消息
。这是我目前拥有的代码,它不会产生任何错误并返回
消息
已经
发送
的
消息
: @app.route(&q
浏览 3
提问于2022-10-02
得票数 0
回答已采纳
3
回答
RabbitMq
- pika - python -发布时丢弃
消息
python
、
rabbitmq
、
amqp
、
pika
message_body.strip())self.logger.info('Sent %d messages' % count)我正在使用这段代码向
RabbitMQ
服务器
发送
消息
。但有时,这并不是将所有
消息
发送
到相应
的
队列。它每次运行时都会丢失随机数量
的
消息
。 我不明白这里有什么问题。
浏览 7
提问于2016-06-08
得票数 8
3
回答
RabbitMQ
-在
消息
到达到期时间后进行路由选择
rabbitmq
、
ttl
、
dead-letter
我最近发现了允许您延迟
消息
的
RabbitMQ
特性,虽然我找不到任何与我需要
的
类似的示例,但它工作得很好: 假设有三种类型
的
消息
: A、B和C。我们有2个delay_queues,具有1小时和2小时
的
'x-message-ttl值。还有3种类型
的
destination_queues --每种类型用于特定
的
消息
类型。我想要实现
的
是,在一个delay_queues
中
的<
浏览 0
提问于2015-05-28
得票数 1
回答已采纳
1
回答
让连接保持对
RabbitMQ
的
开放还是只在必要时打开连接更好?
python
、
rabbitmq
、
pika
我有一个通过一系列测试循环
的
应用程序。在失败
的
测试
中
,它会将一条
消息
发布到
RabbitMQ
队列,其他应用程序将从该队列
中
监控和获取
消息
。有数百个测试,需要几分钟
的
时间才能全部完成。测试会被重复,因为应用程序是定期运行
的
。 我
的
问题是,是否最好打开一个连接一次,让它在循环所有测试之后才能发布?还是只在需要发布
消息
并在
消息
发送
后关闭连接时才建立连接更好?另外,如果我<
浏览 4
提问于2020-05-11
得票数 1
回答已采纳
1
回答
从Python (Pika)将
消息
发布到
RabbitMQ
的
正确队列
中
,以便在.NET (MassTransit)中使用
python
、
.net
、
rabbitmq
、
masstransit
、
pika
我想将一条
消息
从基于Python
的
微服务(使用Pika)发布到基于.NET
的
微服务(使用MassTransit作为事件总线)消耗
的
一个队列
中
。Python发布服务器
的
示例代码如下所示: content_type = 'text/plain
浏览 2
提问于2021-09-16
得票数 0
回答已采纳
1
回答
使用Paho MQTT订阅
消息
时如何读取头部键:值对
python-3.x
、
rabbitmq
、
mqtt
、
paho
、
pika
在使用pika将
消息
发布到
rabbitmq
代理时,我添加了一个标头key:value对,如下所示 properties=
pika.BasicProperties
(如何使用Paho MQTT检索相同
的
消息
头。message.payload, 'utf-8')) print(client.h
浏览 3
提问于2020-12-31
得票数 1
2
回答
如何让
RabbitMQ
更可靠?是否可以让它定期备份其数据(
消息
)?
linux
、
rabbitmq
、
backup
、
reliability
我希望确保在
RabbitMQ
崩溃
的
情况下不会丢失任何内容。有没有可能以某种方式让
RabbitMQ
转储或备份它在磁盘上
的
所有队列?我也听说过,一旦它收到一条
消息
,即使它崩溃了,当它运行起来时,
消息
将是可用
的
。 那么,你有什么建议来让这个过程更可靠呢?
浏览 0
提问于2016-02-17
得票数 2
1
回答
无法读取
RabbitMQ
中
的
所有
消息
php
、
rabbitmq
、
amqp
我创建了
RabbitMQ
侦听器: $AMQP_config['server'], $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);} 我
的
RabbitMQ
服务器上有5条
消息
。我
浏览 1
提问于2015-04-20
得票数 4
1
回答
Rabbitmq
报头交换和确认交付
java
、
python
、
rabbitmq
、
rabbitmq-exchange
我试图在
RabbitMQ
上使用头文件交换,使用混合
的
java和python组件,我需要确认交付。¦ ¦ ¦ ¦ ¦ ¦ body=message,¦ ¦ ¦ ¦ ¦ ¦ ¦
浏览 3
提问于2017-05-09
得票数 4
回答已采纳
1
回答
使用
Rabbitmq
发送
通知
django
、
rabbitmq
、
django-rest-framework
、
long-polling
我正在使用django,django rest框架和
Rabbitmq
,我想要
的
是使用
Rabbitmq
在用户创建评论(如长轮询)后向客户端
发送
通知。我在这里遵循。='task_queue', properties=
pika.BasicProperties
,并在每次创建评论时
发送
消息
"Hello,w
浏览 1
提问于2016-03-29
得票数 0
1
回答
如何在
RabbitMQ
中注入开放
的
竞速跨度?
rabbitmq
、
inject
、
opentracing
我正在使用OpenTracing,并尝试通过
RabbitMQ
传播span。然而,我不明白我应该如何注入跨度,以及如何在以后提取它。这是
发送
消息
的
代码 root_span = tracer.get_span() body=json_messa
浏览 4
提问于2018-07-19
得票数 6
2
回答
是否可以使用
RabbitMQ
直接应答--在Python中使用Pika生成器消费者
的
特性?
python
、
rabbitmq
、
generator
、
pika
、
consumer
我想在Python
中
的
客户机库中使用
RabbitMQ
的
特性。它适用于一个基本
的
消费者。channel.basic_publish( properties=
pika.BasicProperties
(reply_to="amq.
rabbitmq
.reply-to"))
浏览 1
提问于2019-07-01
得票数 2
回答已采纳
1
回答
接收方部分
中
缺少
rabbitmq
消息
python
、
rabbitmq
、
pika
我在我
的
服务器
中
实现了
RabbitMQ
。因此,基本上它所做
的
就是主服务器将
消息
传递给工作服务器。我面临
的
问题是,我传递
的
所有
消息
都不会被服务器接收到。也就是说,如果我
发送
10条
消息
,只会收到其中
的
4条。 body=message,
浏览 0
提问于2016-05-02
得票数 2
2
回答
如何在芹菜任务
中
实现异步
rabbitmq
客户端pika或pyrabbit?
python
、
asynchronous
、
rabbitmq
、
celery
、
pika
我正在使用celery和
rabbitmq
处理大约1000万个任务。该任务
的
输出是存储在远程
rabbitmq
中
的
json。我使用Pika将
消息
发布到远程
rabbitmq
中
的
不同队列。目前我得到了这个错误pika.exceptions.ConnectionClosed: Connection,因为pika不是异步
的
。我发现了另一个异步客户端。但我无法在我
的
代码
中
实现它。是否需要为每个任
浏览 0
提问于2017-11-02
得票数 1
2
回答
我们能加快通过
RabbitMQ
发布
消息
吗?
python-3.x
、
rabbitmq
、
ubuntu-14.04
queue='hello_durable', durable=True) properties =
pika.BasicProperties
now - started_at except Exception as e:
发送
有超过8Gb
的
空闲内存。队列是否持久并不重要。 我们如何加快
发送<
浏览 3
提问于2016-03-09
得票数 4
回答已采纳
2
回答
在
rabbitmq
中
在不存在队列上发布
消息
时如何中止代码
rabbitmq
、
rabbitmq-exchange
、
rabbitmq-c
此外,在我发表之前,我已经设置了必须
的
旗帜为真。当我首先启动服务器时,一切都很好-- .but,我首先启动客户端时遇到了问题,它使用路由密钥发布数据。当客户端发布数据时,代理也
不
例外。需求 当我在不存在
的
队列上发布数据时,我需要异常或错误。
浏览 3
提问于2015-10-01
得票数 3
2
回答
在从
rabbitmq
队列获得应答时,从端点类型地址
中
设置应答类型
json
、
rabbitmq
、
wso2
、
wso2-micro-integrator
rabbitmq
.server.host.name=10.0.0.2&
rabbitmq
.server.port=5672&
rabbitmq
.server.virtual.host=dev&
rabbitmq
.server.vhost=devAuth&
rabbitmq
.queue.name=hello&
rabbitmq
.queue.durable=false&respond whatever&quo
浏览 8
提问于2020-10-20
得票数 0
回答已采纳
3
回答
Pika worker在运行channel.declare_queue时抛出异常
python
、
rabbitmq
、
amqp
、
pika
我正在编写一个python客户机,以接受来自
RabbitMQ
代理
的
作业
消息
,并处理作业,将结果返回到另一个服务器。我将
消息
发送
到
RabbitMQ
代理
的
脚本启动正常,但我
的
工作线程在运行channel.declare_queue(queue='task_queue')时抛出以下错误channel.basic_consume(ProcJ
浏览 0
提问于2012-09-06
得票数 7
回答已采纳
1
回答
NServiceBus:
发送
消息
时访问
RabbitMQ
IBasicProperties
c#
、
.net
、
rabbitmq
、
nservicebus
我将
RabbitMQ
与NServiceBus结合使用。我向某个队列
发送
消息
,第三方服务在队列
中
读取
消息
。结果表明,服务需要将encoding_type
属性
设置为utf-8,而我不能通过NServiceBus设置这个
属性
(或者可以吗?)。我不知道在
发送
消息
时是否有可能访问IBasicProperties of
RabbitMQ
客户端。 不幸
的
是,在行为处理程序
中
获取
属性</e
浏览 5
提问于2022-07-04
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
如何使用Python操作RabbitMQ实现direct关键字发布订阅模式?有录播直播私教课视频教程
MQ对比之RabbitMQ&Redis
九浅一深之RabbitMQ
Python操作rabbitMQ
一文搞懂 RabbitMQ 的重要概念以及安装
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券