如何从表中获取所有列,并使用python将其作为csv文件保存在s3中

bvn4nwqk  于 2021-06-17  发布在  Mysql
关注(0)|答案(1)|浏览(295)
cur = con.cursor()
for i in sample:
    cur.execute("select `count(*)`,cricking_duels_ratings,cast(`sysdate()` as CHAR) from {}".format(i))
    res = cur.fetchall()
    for row in res:
        print(row)
    ob = s3.Object(BUCKET_NAME, '/testing.csv')
    ob.put(Body=row)
    print("done")

当我尝试上述方法时,我得到以下错误
'参数体的类型无效..类型:,有效类型:,类文件对象'
有什么建议吗。。

brqmpdu1

brqmpdu11#

创建一个本地文件,然后使用 upload_file() 将文件复制到s3。这也使得调试更容易,因为您可以查看本地文件的内容,以确保它正确地转换为csv。
我怀疑你的问题与转换 row 转换为包含逗号分隔值的字符串。请参阅:如何在python中迭代cur.fetchall()

相关问题