1

Within my Nifi workflow, I am executing my Python script using ExecuteStreamCommand and at the end of my script, I am using json.dump to dump my results into Json format. My goal is to extract key, values from this json object and use it in the next processor (PutDatabaseRecord). For this purpose, I have attached AttributestoJson processor right after ExecuteStreamCommand but the result of AttributetoJson processor is only showing me the attribute name and not its value.

Also, the content type of the ExecuteStreamCommand processor is of application/avro-binary and I am having hard time converting into other formats.

Result of ExecuteStreamCommand

Result of AttributestoJson

Kiran
  • 11
  • 2
  • Please clarify your specific problem or provide additional details to highlight exactly what you need. As it's currently written, it's hard to tell exactly what you're asking. – Community Aug 30 '23 at 17:56

1 Answers1

0

ExecuteStreamCommand writes all output to the content of the outgoing FlowFile, not to attributes. So it appears your FlowFile content already contains the JSON object, and you should be able to put it directly into PutDatabaseRecord (with a JsonTreeReader to read it in). You can also use UpdateAttribute to set mime.type to application/json to make it easier to view / manipulate downstream.

mattyb
  • 11,693
  • 15
  • 20