opg2.psycabyte错误：无效的数据序列

Question

这就是我要做的。我正在尝试输入一个csv文件到gres数据库。我使用psycopg2和cur_copy_export来完成此操作。但是，我遇到了如下错误。我该怎么做才能克服这个错误？在

提前谢谢

错误：

    cur.copy_expert(sql=copy_sql, file=myfile)
    psycopg2.DataError: invalid byte sequence for encoding "UTF8": 0xdf 0x65
    CONTEXT:  COPY agents, line 1117

我的代码如下：

^{pr2}$

我的数据库编码是“UTF8”格式。我不能改变它，因为它是一个生产数据库。在

Answer 1

copy_source = {'Bucket': srcbucketid, 'Key': file_name}
client.copy(copy_source, srcbucketid, 'tmp/{}'.format(file_name))
key = ('s3://'+srcbucketid+'tmp/'+file_name)
print(key)
BLOCKSIZE = 1024*1024
with s3.open('s3://'+srcbucketid+'/'+file_name, 'rb') as inf:
    with s3.open('s3://'+srcbucketid+'/tmp/'+file_name, 'wb') as ouf:
        while True:
            data = inf.read(BLOCKSIZE)
            if not data: break
            converted = data.decode('latin1').encode('utf-8')
            ouf.write(converted)