问题标签 [aiopg]

我正在查看使用 sqlalchemy 的 aiopg 使用示例，这些行让我害怕：

我不想在使用 sqlalchemy 时执行原始 sql 查询。但是我找不到任何其他方法来实现相同的逻辑。我的尝试是：

1)

这提出了：

sqlalchemy.exc.UnboundExecutionError：表对象“tbl”未绑定到引擎或连接。如果没有要执行的数据库，则无法继续执行。

我也找不到将表绑定到引擎的方法，因为aiopg 不支持 metadata.create_all

2)

这提出了：

psycopg2.errors.UndefinedTable：表“tbl”不存在

似乎DropTable构造不IF EXISTS以任何方式支持部分。

So, the question is, is there any way to rewrite await conn.execute('DROP TABLE IF EXISTS tbl') statement into something without raw sql when using aiopg + sqlalchemy?

我知道有一个包要求aiopg在asyncio友好的连接中使用 Postgresql。Presto 是否有类似的版本/包？我正在尝试在 Python 的 Presto 连接中实现并发查询。

提前致谢！

我试图在我的 websocket 中只有一个数据库连接，并将此信息返回给每个连接的客户端。有可能这样做吗？

有我当前的代码：

目前，每次客户端监听我的 websocket 时，我的数据库中都会有一个新连接。每个客户端都会获得相同的内容，所以我不需要它们连接到数据库，只需要我的 websocket。

我尝试拆分我的代码（连接到另一个正在连接这个的 websocket），但我遇到了同样的问题。

任何提示将不胜感激。

谢谢

我正在尝试做一些我相当确定使用 AIOPG 很简单的事情，它可以使用 sqlalchemy 的核心 API。我的 SQL 不是很好，所以这就是我跌倒的地方。

楷模

因此，我只是想获取所有schools具有特定subject_categoryID 的教学科目。

目前我有：

当我尝试插入复合主键连接时返回 0 行：

似乎不可能将复合主键作为值插入......但是在这种情况下如何插入键？不幸的是，我在 SQLAlchemy 文档中没有找到一些例子......（

我为一些单元测试编写了以下代码。想知道是否有人能指出我正确的方向。我知道我错过了一些东西，但无法弄清楚。

错误：

在这里你可以看到用户模型及其方法

有两个功能，第一个是检查用户是否存在于数据库中，第二个是添加一个新用户到数据库。所以主要问题是 create_user 函数工作正常，但如果我在那里添加一个 check_user，什么都不会发生。在下面查看我调用此函数的视图方法

有人可以告诉我有什么问题吗？日志是空的，我没有收到任何错误，但也没有任何反应。自由回答。感谢大家

我正在使用已配置为使用 以下功能进行连接的编码/数据库（ https://www.encode.io/databases/database_queries/ ）：postgresql+aiopg://DBUSER:DBPASS@1.2.3.4:1234/SOMEDB

运行时，抛出以下错误：

注意 subbed 变量周围的引号。如果我对查询进行硬编码，"SELECT * from rally_iteration limit 100" 一切都会按预期工作。

任何帮助表示赞赏。谢谢！

我正在使用官方文档学习 aiohttp，并且在我必须获得数据库连接的步骤中，代码引发异常。我有一个函数并调用它： app.on_startup.append(function) 就像在文档中一样。函数代码如下：

以下例外：

请帮我。我不知道该怎么办

我想使用 Telethon (Telegram bot) 和 aiopg (PostgreSQL) 库。

马拉松示例：

aiopg 示例：

我想在同一个 python 脚本中使用两者。我试图找到解决方案，它可能是 asyncio.gather(...)，但我不知道如何结合这两个库，如何启动两个循环。你能帮我么？