可以在airflow.providers.amazon.aws.operators.sql_to_s3.SqlToS3Operator文件中的_copy_to_s3函数中将索引去掉,具体代码示例如下:
copy_query = "{0} {1} {2} '{3}' {4}".format( self.copy_query_prefix, self.copy_query_columns, self.copy_query_from, self.tmp_path, self.copy_query_suffix, )
copy_query = "{0} {1} {2} '{3}' {4}".format( self.copy_query_prefix, self.copy_query_columns.strip("索引"), self.copy_query_from, self.tmp_path, self.copy_query_suffix, )
需要将“copy_query_columns.strip("索引")”中的“索引”替换为实际的不需要的索引名称。如有多个索引需要去掉,可以在strip()中传入多个索引名称,以逗号隔开即可。