Hi, I am facing a problem with my Execute script, My python script generate a FlowFile with an attribute : flowFile = session.get()
try:
if (flowFile != None):
Table_name = flowFile.getAttribute('Table_Name')
Table_path = flowFile.getAttribute('Table_Path')
Table_schema = flowFile.getAttribute('Table_Schema')
Table_path = Table_path.split(',')
Table_schema = Table_schema.split(',')
project_query = '{'
collection = Table_path[0]
father = Table_path[-1]
for table in Table_path:
project_query = project_query + r'"{}._id" : 1, '.format(table)
for column in Table_schema:
project_query = project_query + r'"{}.{}.{}" : 1, '.format(father,Table_name,column)
project_query = project_query[:-2]
project_query = project_query + '}'
flowFile = session.putAttribute(flowFile, 'project_query', project_query)
flowFile = session.putAttribute(flowFile, 'Collection', collection)
session.transfer(flowFile, REL_SUCCESS)
except Exception as e:
flowFile = session.putAttribute(flowFile, 'ERROR', e)
session.transfer(flowFile, REL_FAILURE) This scripts caused my node to disconnect, any advice ?
... View more
