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'}.
AmqpConsumer 从给定队列中获取 amqp 数据并放入流中。
在 amqp$headers 属性中设置的 Amqp 数据头值。
所以我尝试通过 updateAttribute 处理器和引用来获取这个属性,但是它报错了。
数据如上。但是我无法通过 updateAttribute.
达到如下所示How can set the amqp$headers in flow to header attribute.
您引用属性的语法错误,通常是 ${amqp$headers},但在您的情况下,由于属性名称中有一个“$”,您引用它就像 ${'amqp$headers'}.