这是因为在PostgreSQL数据库中,存在某些非utf-8编码的字符。为了解决这个问题,我们需要将PostgresHook的连接选项中的client_encoding设置为UTF8,示例如下:
from airflow.hooks.postgres_hook import PostgresHook
postgres_hook = PostgresHook(postgres_conn_id='my_postgres_connection_id', client_encoding='UTF8')
这样就能避免出现编解码问题了。