问题标签 [asyncpg]

我正在尝试创建一个连接池，如文档中所示来测试模块。

这是我的最后一次尝试：

我在第 4 行收到一个 SyntaxError，指向“with”：

从终端上的 Python 解释器运行代码会产生相同的结果。

Python 版本是 3.6.5，从终端运行脚本python3 script.py

我为我的 discord.py 机器人使用了asyncpg Pool，但正如我在标题中所说，它随机停止响应。使用池的命令不起作用，但其他命令起作用，而且我确信我在使用它们后会关闭所有连接。我尝试在谷歌上搜索，但没有找到任何东西

这是我创建池的方式：

编辑：我认为这些信息还不够，我决定添加一些内容。我没有任何异常或错误。我想可能是因为池的生命周期并将其更改为0（禁用机制），但这不起作用

我需要从数据库中获取带有所需参数的行。我正在使用 asycpg 与 Postgresql 一起工作这是我的代码：

当我启动我的脚本时，我收到了这个错误：

问题是什么？PS我正在使用python3

我一直在使用 psycopg2 来管理我的 PostgreSQL 数据库中的项目。最近有人建议我可以通过在我的代码中使用 asyncio 和 asyncpg 来改进我的数据库事务。我查看了 Stack Overflow 并阅读了文档中的示例。我已经能够创建表和插入记录，但是我无法获得我想要的执行反馈。

例如，在我的 psycopg2 代码中，我可以在插入记录之前验证表是否存在。

我无法使用 asyncpg 获得相同的反馈。我该如何做到这一点？

我还在学习 PostgreSQL。在我的测试期间，我只在 psycopg2 和现在的 asyncpg 中使用了 INSERT 语句。我现在需要更新我的测试数据库中的数据，而不是全部替换。

我目前正在尝试在测试表中进行简单的替换测试，然后再转到具有更多数据的开发表。

我想用表 users 中已经存在的名称替换 CONFLICT 中的任何 $1 名称。我正在尝试通过 asyncpg 传递给数据库的查询代码。我不断收到语法错误，所以我对如何纠正这些错误有点迷茫。

此查询的正确语法是什么？

更新：

使用 asyncpg 时收到此错误消息：

使用 psycopg2 时收到此错误消息：

这是我用来执行 INSERT 的 asyncpg 代码：

我需要每 10 秒远程插入几十行。我不确定我是否应该async with connection在每个插入周围使用，关闭连接并每隔 10 秒重新打开一次，或者只await conn = ...使用一次并永远处理打开的连接。

请根据其他行数和插入频率解释决定在什么时候改变。

包文档https://magicstack.github.io/asyncpg/current/api/index.html#prepared-statements。

唯一的协程似乎是用准备好的语句处理 SELECT 查询。文档列表cursor, explain, fetch, fetchrow, fetchval. asyncpg是否支持准备好的 INSERT 语句似乎并不明显。我尝试stmt.execute(...)猜测，确实该PreparedStatement对象没有属性execute。

我正在尝试通过 asyncpg API 使用查询参数在 postgresql 数据库的表中插入值。我这样创建了我的表：

我已经尝试像这样直接在 BIGINT 中转换参数：$1:BIGINT但我得到了同样的错误

cat 是一个 int 并且角色是一个 int 数组

应该将 cat 和角色插入 my_table 但我刚刚收到错误：syntax error at or near "$1"

我提供数据库的日志以防万一

编辑了我的代码 - 现在它可以工作了我正在尝试通过 asyncpg 连接池从我的 Postgres 数据库中异步获取一些日期。基本上我的数据库包含大约 100 个不同的表（每个城市），我试图尽可能快地在一帧中收集所有数据。

Python 3.6.5 :: Anaconda, Inc.

给我这个错误：

Traceback（最近一次调用最后一次）：文件“”，第 319 行，在文件“/Users/fixx/anaconda3/lib/python3.6/asyncio/base_events.py”中，第 468 行，在 run_until_complete 返回 future.result() 文件中“”，第 308 行，在主文件中“/Users/fixx/anaconda3/lib/python3.6/asyncio/tasks.py”，第 594 行，在 set(coros_or_futures) 中收集 arg：TypeError: unhashable type: 'list '

我想不通，为什么？我的 sqls 在元组中！

我正在尝试使用 asyncpg 将大型 Pandas 数据帧写入 postgres，但在尝试使用 copy_to_table 函数时出现错误。

我有使用 psycopg2.copy_from 使用 StringIO 的工作代码，但是当我尝试使用 asyncpg 实现类似的模式时它不起作用

使用 StringIO

这是我使用 StringIO 得到的错误：

我还尝试将数据框加载到 BytesIO 对象中，但我遇到了与 to_csv 不同的问题：

我很确定我在这里将数据帧转换为错误的字节。无论哪种方式，我只想使用 asyncpg 通过 COPY 命令将大型数据帧加载到 postgres 中 - 而不是逐行加载。