要确定或检查所有的流文件是否已被处理完，可以使用Apache NiFi的监控组件和状态信息。

以下是一个示例代码，可以通过NiFi的REST API获取流程中所有组件的状态信息，并检查所有的流文件是否已被处理完：

import requests
import json

# NiFi的URL和端口
nifi_url = 'http://localhost:8080'

# 获取流程状态信息的API
status_api = f'{nifi_url}/nifi-api/flow/status'

# 发送GET请求获取状态信息
response = requests.get(status_api)
status_data = json.loads(response.text)

# 获取所有的组件状态信息
component_statuses = status_data['controllerStatus']['aggregateSnapshot']['nodeSnapshots'][0]['componentStatusSnapshots']

# 遍历所有组件状态信息
for component_status in component_statuses:
    # 检查组件类型为ProcessGroup的状态
    if component_status['componentType'] == 'ProcessGroup':
        # 获取组件的状态信息
        component_id = component_status['componentId']
        component_name = component_status['componentName']
        component_state = component_status['componentState']

        # 检查组件是否处于运行中状态
        if component_state == 'RUNNING':
            print(f'Process Group "{component_name}" is still running')

# 如果所有Process Group的状态都不是运行中状态，则表示所有的流文件已被处理完
print('All flow files have been processed')

请注意，这只是一个简单的示例，实际情况可能因NiFi的配置和流程的复杂性而有所不同。您可能需要根据自己的需求进行适当的修改和调整。