Nifi AmqpConsumer 获取 amqp$headers 属性

Question

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

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

所以我尝试通过 updateAttribute 处理器并使用引用来获取此属性，但报错。

数据如上。但我无法通过 updateAttribute 达到以下目标。

如何将 amqp$headers in flow 设置为 header 属性。

Answer 1

您引用属性的语法是错误的，通常是 ${amqp$headers}，但在您的情况下，由于属性名称中有一个“$”，因此您可以像 ${'amqp$headers' 一样引用它}。