NIFI Генерация нескольких потоковых файлов из Jason для атрибутов с использованием Python и Excutescript - PullRequest
Новая
       8

NIFI Генерация нескольких потоковых файлов из Jason для атрибутов с использованием Python и Excutescript

0 голосов
/ 24 января 2019

Итак, у меня есть файл jason, содержащий несколько конфигураций, но я бы хотел получить общий файл потока из этого jason и поместить все настройки в атрибут. Могу ли я использовать этот скрипт или как я могу сделать

, это мой код?ошибка в originalFlowFile = сеанссодержит атрибуты shop_name и shop_id 

import json
import java.io
from org.apache.commons.io import IOUtils
from org.apache.nifi.processor.io import StreamCallback

flowFile = session.get()
# text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
# obj = json.loads(text)
flowfiles_list = []

# outputStream.write(bytearray(json.dumps(obj.keys(), indent=4).encode('utf-8')))
shopobject = [{"shop_name": "Animo", "shop_id": "12344"}, {"shop_name": "Sennheiser-TH", "shop_id": "8991604793"}]

for obj in shopobject:
    newFlowFile = session.create(flowFile)
    newFlowFile = session.putAttribute(newFlowFile, "shop_name", obj['shop_name'])
    newFlowFile = session.putAttribute(newFlowFile, "google", obj['shop_id'])
    flowfiles_list.append(flowFile)


session.transfer(flowfiles_list, REL_SUCCESS)
session.remove(flowFile)
...