Как вставить json данных из процессора listenhttp в процессор ExecuteStreamCommand с помощью Nifi - PullRequest
Новая
       6

Как вставить json данных из процессора listenhttp в процессор ExecuteStreamCommand с помощью Nifi

0 голосов
/ 09 февраля 2020

Я пытаюсь получить json данные из ListenHttp и передать их в python сценарий с помощью команды executetestream. Я хочу, чтобы мои Json данные были динамически назначены переменной с именем Data. Я использовал поток ListenHttp -> executetestreamcommand или предложил какой-нибудь скрипт python для прямого получения данных curl http json. 

   
import json
import sys






   


def insert(Sensor_id,Location_ip,Sensor_value,Sensor_unit):
   print(Sensor_id)

Data=  json.load(sys.stdin) #I want my json data from listenhttp into be assigned dynamically to variable data
json_str=json.dumps(Data)
d=json.loads(json_str)
Sensorvalue=d['Sensor_value']
Sensor_id=d['Sensor_id']
Sensor_unit=d['Sensor_unit']
Location_ip=d['Location_ip']
Sensor_value=int(Sensorvalue,16)


insert(Sensor_id,Location_ip,Sensor_value,Sensor_unit)
...