我想使用s3 bucket中的dataframe从csv文件交换列。
数据帧
具有具有列名的标题行(
sa_instance_state, data_interval_start,NAME
)
:
def modify_csv(**kwargs):
s3=boto3.client('s3')
read_file = s3.get_object(Bucket=Bucket, Key=Key)
df = pd.read_csv(read_file['Body'],sep=',')
print(df)
输入数据帧
print(df)
sa_instance_state data_interval_start NAME
<sqlalchemy.orm.state.InstanceState1> 2022-07-17 12:55:00+00:00 XYZ
<sqlalchemy.orm.state.InstanceState2> 2022-07-17 12:58:00+00:00 abx
预期结果:
NAME sa_instance_state data_interval_start
XYZ <sqlalchemy.orm.state.InstanceState1> 2022-07-17 12:55:00+00:00
abx <sqlalchemy.orm.state.InstanceState2> 2022-07-17 12:58:00+00:00