如果您想在Airflow中返回StringIO缓冲区,请按照以下步骤操作:
from io import StringIO
string_io_buffer = StringIO()
string_io_buffer.write('Some data')
data = string_io_buffer.getvalue()
string_io_buffer.close()
上一篇:AirflowException:Dag无法找到;可能是因为不存在或解析失败
下一篇:Airflow反向代理和DAG隔离