我注意到在java SDK中,有一个函数可以让你编写csv文件的标题。https://cloud.google.com/dataflow/java-sdk/JavaDoc/com/google/cloud/dataflow/sdk/io/TextIO.Write.html#withHeader-java.lang.String- https://cloud.google.com/dataflow/java-sdk/JavaDoc/com/google/cloud/dataflow/sdk/io/TextIO.Write.html#withHeader-java.lang.String-
这个功能是否反映在 python SDK 上?
您现在可以使用文本接收器写入文本并指定标题。
从文档中:
class apache_beam.io.textio.WriteToText(
file_path_prefix, file_name_suffix='',
append_trailing_newlines=True, num_shards=0,
shard_name_template=None, coder=ToStringCoder,
compression_type='auto', header=None)
所以你可以使用下面的代码:
beam.io.WriteToText(bucket_name, file_name_suffix='.csv',
header='colname1, colname2')
如果您需要详细信息或检查其实现方式,可以在此处找到完整的文档:https://beam.apache.org/documentation/sdks/pydoc/2.0.0/_modules/apache_beam/io/textio.html#WriteToText https://beam.apache.org/documentation/sdks/pydoc/2.0.0/_modules/apache_beam/io/textio.html#WriteToText
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)