4

我正在用我编写的一些代码进行以下（相对）简单的调用：

pickups = session.query(Pickup).filter(Pickup.firebase_run_id == run_id).all()

我对此代码有两组集成测试，一组在本地运行并使用psycops2TLS，另一组在 GCP 开发环境（GCP 云功能）中运行并使用pg8000UNIX 套接字（GCP 要求（？）云功能通过 UNIX 套接字连接到 Cloud SQL - 请参见此处）。本地集成测试运行良好。但是，开发测试可靠地失败并出现以下错误：

    Traceback (most recent call last):
      File "/user_code/main.py", line 245, in GET_run
        response = run_get(run_id)
      File "/user_code/rubbish_geo_client/ops.py", line 686, in run_get
        pickups = session.query(Pickup).filter(Pickup.firebase_run_id == run_id).all()
      File "/env/local/lib/python3.7/site-packages/sqlalchemy/orm/query.py", line 3319, in all
        return list(self)
      File "/env/local/lib/python3.7/site-packages/sqlalchemy/orm/query.py", line 3481, in __iter__
        return self._execute_and_instances(context)
      File "/env/local/lib/python3.7/site-packages/sqlalchemy/orm/query.py", line 3503, in _execute_and_instances
        querycontext, self._connection_from_session, close_with_result=True
    TypeError: expected bytes, str found

这个特定的函数调用实际上只是这种失败的一个例子；我所有的数据库调用都失败并出现相同的_execute_and_instances错误！

也许有人对解决此问题的方法有所了解？

4

3 回答 3

13

pg8000在其实现中存在一个长期存在的错误，sqlalchemy驱动程序刚刚修补了该错误。新的pg8000维护者最近为这个问题引入了一个补丁，并发布了一个pg8000包含修复的新版本。不幸的是，这具有破坏解决方法的副作用sqlalchemy。

在sqlalchemy更改其驱动程序以尊重此补丁之前，目前最好的解决方案是pg8000从 1.16.6 降级到 1.16.5 或更低版本。

您可以使用pip install pg8000<=1.16.5.

作为参考，请参阅以下对话：GH#commitcomment-43174891，GH#53。

于 2020-10-25T01:45:31.833 回答
0

SQLAlchemy 1.4+支持pg8000。

于 2021-04-04T10:16:16.720 回答
0

替代工作

pool.dialect.description_encoding = None

资料来源： https ://github.com/sqlalchemy/sqlalchemy/issues/5645#issuecomment-707879323 https://github.com/GoogleCloudPlatform/python-docs-samples/blob/main/cloud-sql/postgres/sqlalchemy/main .py

于 2021-12-16T04:32:53.100 回答