В моем конвейере у меня есть файл потока, который содержит некоторые данные, которые я хотел бы добавить в качестве атрибутов в файл потока. Я знаю, что в Groovy я могу добавить атрибуты в потоковые файлы, но я менее знаком с Groovy и гораздо удобнее использовать Python для разбора строк (что мне нужно сделать, чтобы извлечь значения эти атрибуты). Вопрос в том, могу ли я достичь этого в Python, когда я использую ExecuteStreamCommand для чтения файла с sys.stdin.read() и записи моего файла с sys.stdout.write()?
Так, например, я использую приведенный ниже код для извлечения метки времени из моего потокового файла. Как мне добавить ts в качестве атрибута при записи ff?
import sys
ff = sys.stdin.read()
t_split = ff.split('\t')
ts = t_split[0]
sys.stdout.write(ff)