问题标签 [asyncpg]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
879 浏览

python - Asyncpg“$1 或附近的语法错误”错误

我正在尝试通过asyncpg库传递参数来为我的 Postgres 数据库创建用户:

但是,当我尝试运行代码时,出现以下错误:
asyncpg.exceptions.PostgresSyntaxError: syntax error at or near "$1"

我知道我无法将表或数据库名称作为参数传入asyncpg,但我找不到任何关于用户名或密码的类似信息。

如果是这种情况,请告诉我,或者我可能需要以某种方式格式化login和变量的内容才能正常工作?password

0 投票
0 回答
1466 浏览

python - Asyncpg/PostgreSQL (python/discord.py)

我遇到了一个问题,即我的不和谐机器人在流量负载后停止回复使用数据库(postgresql 和 asyncpg)的命令。

我检查了数据库,它没有离线或任何东西,我也没有收到任何错误。

help工作正常,因为它不使用数据库

我如何创建/使用连接:

关于我可能做错了什么的任何想法?

我试过使用 try/except 没有得到任何东西

在那里添加了一堆调试打印,没有过去

15 | voice = await self.bot.pg\_conn.fetchrow("SELECT \* FROM voice\_channels WHERE user\_id = $1", id)

并尝试为 fetch 添加超时,但没有做任何事情。虽然当我做键盘中断时,它在关闭并运行打印之前从获取中出来。

如果有人可以帮助我,我将不胜感激。

0 投票
1 回答
1389 浏览

python-3.7 - asyncpg.exceptions.DataError:查询参数的输入无效

我 asyncpg 使用库通过池连接到 mydb。要执行此代码块,我遇到了一个错误:asyncpg.exception.Data Error: invalid input for query argument $10: '2019-12-31' ('str' object has no attribute 'toordinal')

我的代码:

在我的数据库中,“u_reg_date”字段的类型为“date”。如果您使用 {} 符号而不是 $,那么一切正常。我想知道为什么以及我做错了什么,尽管从文档来看我做的一切都是正确的。谢谢。新年和圣诞节快乐!

0 投票
0 回答
683 浏览

python - 在 asyncpg 中出现“准备好的语句错误”

我正在尝试通过使用连接池来处理来自 PostgreSQL 服务器的一些数据。有一个警告提到了这个问题,这显然是由于使用了 'pgbouncer' 工具见下文

但是我正在使用该createpool()函数来获取连接对象:

0 投票
1 回答
246 浏览

python - 等待协程并将结果分配给协程外部的变量

我希望能够制作一个我可以调用的 utils 文件,该文件使用所有从数据库请求数据的命令列表:

等等。我想在另一个文件中使用import. 每次命名都有什么缺点pg_con吗,有没有办法处理它,所以我不必这样做?有没有更好的方法来处理这个问题?

0 投票
1 回答
779 浏览

python-3.x - Sanic Web 框架性能

我有一个关于 sanic / asyncpg 性能的问题要问。

在测试期间,不断发生奇怪的事情(也许是设计使然)。

首先让我解释一下测试过程。很简单。

我使用 locust 通过设置最大用户数来尽可能多地推送服务器。

测试脚本是:

它用于测试以下代码。注意 asyncpg 正在调用 potgresql sleep 函数来模拟负载:

问题是,在随机时间后,服务器对 cca 变得无响应(不返回 503 或任何其他代码)。60 秒。进程也挂起(我可以看到它ps aux并且 CTRL+C 不能杀死它。)

这可能是有问题的,因为它很难检测到,也很难确定我们可以向服务器发送请求的速率。

这可能是配置(sanic/asyncpg)的问题吗?

设置 nginx/sanic 请求超时是否是规避此问题的唯一选择?

0 投票
2 回答
377 浏览

python-asyncio - 如何使用 psycopg2 或 asyncpg 将我的 postgres 连接池传递给 Dask 工作人员?

我希望我的 Dask 工作人员从 a 中获取 Postgres 连接ThreadedConnectionPool,但是当像这样通过池时

我收到序列化错误,例如:

此外,虽然我一直在尝试这个,psycopg2但我也很喜欢这个工作asyncpg(性能原因)。但是,这增加了使用awaitasyncfromasyncio

尽管我似乎最终会遇到相同类型的错误,例如

非常感谢任何建议(或替代方案?)!

0 投票
0 回答
173 浏览

postgresql - 任务被破坏,但它是未决错误

我有一个名为 engine.py 的类,它返回连接池。

然后我有另一个名为 model.py 的模块

函数get_contacts是从 swagger api 调用的,但是当我多次点击这个 api 时,我得到了

0 投票
0 回答
207 浏览

python - 索引 0 处的无效数组元素:需要 datetime.date 或 datetime.datetime 实例,得到 'int' asyncpg

我被这个难以解释的 asyncpg 错误所困扰。该错误告诉我索引 0 的类型错误,在接收 int 时需要日期时间:

这很奇怪,因为架构是:

我的数据如下所示:

没有添加到第一个元素,因为我在另一篇文章中看到了,没有它,同样的错误。

和异步功能:

非常不清楚的错误,希望anynoe可以帮助解决这个问题。

0 投票
0 回答
580 浏览

python - 如何从 asyncpg 库连接到 pgbouncer?

我已经使用 asyncpg 实现了 pgbouncer 以及 asyncpg 本机池实现。虽然我可以通过 pgbouncer 发送许多并发请求,但是对于 1000 个并发请求,我的 p95 接近 8 秒,而与 asyncpg 本机池实现一样,p95 仅高于 1.5 秒。

为什么会有这么大的性能差异?这是从 asyncpg 连接到 pgbouncer 的正确方法吗?

代码示例:

  1. 使用 asyncpg 和 pgbouncer:
  1. 本机 asyncp 池实现

pgbouncer.ini 文件: