Nifi AmqpConsumer 获取 amqp$headers 属性

Nifi AmqpConsumer get amqp$headers attribute

AmqpConsumer 从给定队列中获取 amqp 数据并放入流中。

amqp$headers 属性中设置的 Amqp 数据头值。

所以我尝试通过 updateAttribute 处理器和引用来获取这个属性,但是它报错了。

数据如上。但是我无法通过 updateAttribute.

达到如下所示

How can set the amqp$headers in flow to header attribute.

您引用属性的语法错误,通常是 ${amqp$headers},但在您的情况下,由于属性名称中有一个“$”,您引用它就像 ${'amqp$headers'}.