Thank you @Matt Burgess... i have tried to use my code with executeScript processor but it didn't work , please check and let me know if i'm missing anything or if you have another same code please share it with me ,Will really appreciate: import java.io from org.apache.commons.io import IOUtils from java.nio.charset import StandardCharsets from org.apache.nifi.processor.io import StreamCallback from time import sleep class WriteContentCallback(StreamCallback): def __init__(self): pass def process(self, inputStream,outputStream): text = IOUtils.toString(inputStream, StandardCharsets.UTF_8) outputStream.write(bytearray(start(text).encode('utf-8'))) def start(): time_periods = working_periods_table.find_all() today = datetime.datetime.now().isoweekday() for day in time_periods: if day["day"] == today: start_time = day["work_start_at"] end_time = day["12:35"] while True: if datetime.datetime.now() == end_time: schedule.every().week.at(end_time).do(record_activity(idle_time=300)) break else: sleep(100) flowFile = session.get() if flowFile != None: flowFile=session.write(flowFile, WriteContentCallback()) flowFile = session.putAttribute(flowFile, "filename", "true") session.transfer(flowFile, REL_SUCCESS) session.commit()
... View more
