首页
学习
活动
专区
圈层
工具
发布
    • 综合排序
    • 最热优先
    • 最新优先
    时间不限
  • 来自专栏AI篮球与生活

    超实用的 Python 技巧,异步操作数据库!

    异步操作PostgreSQL 异步操作PostgreSQL的话,我们有两个选择,一个是asyncpg库,另一个是 aiopg库。 asyncpg是自己实现了一套连接驱动,而aiopg则是对psycopg2进行了封装,个人更推荐asyncpg,性能和活跃度都比aiopg要好。 下面来看看如何使用asyncpg,首先是安装,直接pip install asyncpg 即可。 import asyncio import asyncpg async def main(): conn = await asyncpg.connect("postgres://postgres import asyncio import asyncpg async def main(): conn = await asyncpg.connect("postgres://postgres

    3.4K20编辑于 2023-03-01
  • 来自专栏技术汇总专栏

    深入Python异步编程:概念、应用场景与实践

    2. asyncpg:异步PostgreSQL数据库驱动asyncpg是一个基于asyncio的异步PostgreSQL数据库驱动,它提供了高性能和易用性,并且与Python的异步编程模型完全兼容。 下面是一个简单的示例,演示了如何使用asyncpg进行异步数据库查询:import asyncioimport asyncpgasync def main(): conn = await asyncpg.connect in values: print(row) await conn.close()if __name__ == "__main__": asyncio.run(main())通过asyncpg 除此之外,我们还探讨了一些异步编程的进阶应用,如aiohttp、asyncpg等库的使用,并提供了相应的示例代码。

    83820编辑于 2024-08-08
  • 来自专栏Python中文社区

    基于Sanic的微服务基础架构

    使用asyncpg为数据库驱动,进行数据库连接,执行sql语句执行。 使用aiohttp为Client,对其他微服务进行访问。 使用peewee为ORM,但是只是用来做模型设计和migration。 ORM使用peewee, 只是用来做模型设计和migration, 数据库操作使用asyncpg。 is the fastest driver among common Python, NodeJS and Go implementations 使用asyncpg为数据库驱动, 对数据库连接进行封装 不使用ORM做数据库操作,一个原因是性能,ORM会有性能的损耗,并且无法使用asyncpg高性能库。另一个是单个微服务是很简单的,表结构不会很复杂,简单的SQL语句就可以处理来,没必要引入ORM。 :https://github.com/MagicStack/asyncpg benchmarks:https://magic.io/blog/asyncpg-1m-rows-from-postgres-to-python

    4K70发布于 2018-03-26
  • 来自专栏飞鸟的专栏

    FastAPI基础-协程

    例如,如果我们使用 PostgreSQL 数据库,可以使用 asyncpg 库来实现异步访问。 下面是一个示例:import asyncpgasync def get_database_connection(): conn = await asyncpg.connect("postgresql

    84710编辑于 2023-05-07
  • 来自专栏飞鸟的专栏

    FastAPI基础-异步

    例如,如果我们使用 PostgreSQL 数据库,可以使用 asyncpg 库来实现异步访问。 下面是一个示例:import asyncpgasync def get_database_connection(): conn = await asyncpg.connect("postgresql

    1.3K10编辑于 2023-05-07
  • 来自专栏SeanCheney的专栏

    Awesome Asyncio 《碉堡的Asyncio·中文版》Awesome-Asyncio-CN

    数据库驱动 数据库的驱动库 asyncpg - 快速访问 PostgreSQL 数据库客户端的异步驱动。 asyncpgsa - 提供 Sqlalchemy Core 支持的 Asyncpg。 GINO - 基于 SQLAlchemy Core 和 asyncpg 方言的轻量级 Python 异步 ORM。

    3K40发布于 2018-08-16
  • 来自专栏Python无止境

    国人开源的异步 Python ORM:GINO

    基于 MagicStack 出品必属精品的、一秒可读百万行的 asyncpg[25],以及 uvloop[26](可选)的强力加持,GINO 跑起来也是可以飞快的,被广泛应用于诸如实时汇率、聊天机器人、 It is an integration of SQLAlchemy core and asyncpg. aioh2 / 2016 This is an integration of an HTTP/2 业余时间除了开发维护 GINO 项目外,还会偶尔修一修 uvloop、asyncpg 和 CPython 的 bug :P 7. 参考文献 [1] Facebook. Tornado. URL: https://pgjones.gitlab.io/quart/. [21] Canopy. asyncpgsa - A wrapper around asyncpg for use with URL: https://python-gino.org/docs/zh/master/how-to/schema.html#gino-orm. [25] MagicStack Inc. asyncpg

    3.2K21发布于 2020-05-14
  • 来自专栏人工智能应用

    使用asyncio构建高性能网络爬虫

    核心技术栈 asyncio:Python原生异步I/O框架 aiohttp:异步HTTP客户端/服务器 BeautifulSoup/lxml:HTML解析库 aiomysql/asyncpg

    23710编辑于 2025-08-01
  • 来自专栏AI学习笔记

    [PostgreSQL]模型训练数据库连接池耗尽:PostgreSQL调优实录

    _pool: Optional[asyncpg.Pool] = None async def init(self): """初始化连接池""" self. _pool = await asyncpg.create_pool( self.dsn, min_size=self.min_size, _pool.acquire() async def release_connection(self, conn: asyncpg.Connection): """释放连接"" conn: yield conn@app.get("/features/{sample_id}")async def get_features(sample_id: str, conn: asyncpg.Connection 连接超时说明模型训练SQLAlchemy QueuePool51530s长事务,连接保持特征服务NullPool0010s短查询,不保留管理后台QueuePool203060s人机交互,容忍度高数据导入AsyncPG

    42511编辑于 2025-12-09
  • 来自专栏人工智能应用

    Python异步编程实战

    process_task(task) queue.task_done() 连接池管理策略 分布式任务队列集成 五、性能调优路线图 UVLOOP替代方案加速事件循环 使用asyncpg

    21710编辑于 2025-08-01
  • 来自专栏信数据得永生

    SqlAlchemy 2.0 中文文档(五十八)

    [postgresql] [bug] [regression] 修复了在 2.0.24 版本中由 #10717 引起的 asyncpg 方言中的回归,该版本中现在尝试在终止之前优雅地关闭 asyncpg 受影响的方言包括 asyncpg,所有 mssql 方言。 在 asyncpg 连接的情况下,将使用 asyncpg 特定的terminate()方法来更优雅地结束该连接,而不仅仅是将其丢弃。 另见 DOMAIN 参考:#7316 [postgresql] [usecase] [asyncpg] 添加了可重写方法 PGDialect_asyncpg.setup_asyncpg_json_codec 和 PGDialect_asyncpg.setup_asyncpg_jsonb_codec,用于在使用 asyncpg 时注册这些数据类型所需的 JSON/JSONB 编解码器。

    2.3K10编辑于 2024-08-01
  • Python事件循环教程:如何使用asyncio事件循环 | Python异步编程指南

    asyncio.run(main())数据库操作使用异步数据库驱动提高数据库访问效率:import asyncioimport asyncpgasync def query_db(): conn = await asyncpg.connect

    65310编辑于 2025-08-08
  • 来自专栏技术汇总专栏

    使用Python进行异步微服务架构的设计与实现

    # database.py import asyncpg async def connect_to_database(): return await asyncpg.connect(user

    2.8K20编辑于 2024-07-31
  • 来自专栏人工智能应用

    FastAPI 实用教程:构建高性能 Python Web API 的终极指南

    异步数据库驱动 # 使用asyncpg连接PostgreSQL DATABASE_URL = "postgresql+asyncpg://user:password@localhost/dbname"

    1.9K10编辑于 2025-08-01
  • 优化 Python 爬虫性能:异步爬取新浪财经大数据

    数据存储优化 异步数据库写入:如aiomysql、asyncpg。 批量写入:减少I/O次数。

    82410编辑于 2025-06-19
  • 来自专栏信数据得永生

    SqlAlchemy 2.0 中文文档(五十九)

    这允许 asyncpg 放弃连接而无需等待可能导致长时间超时的响应。 References: #7561 [postgresql] [bug] [asyncpg] Improved support for asyncpg handling of TIME WITH References: #7295 postgresql [postgresql] [usecase] [asyncpg] Added overridable methods PGDialect_asyncpg.setup_asyncpg_json_codec and PGDialect_asyncpg.setup_asyncpg_jsonb_codec codec, which handle the required task of registering References: #7284 [postgresql] [bug] [asyncpg] Changed the asyncpg dialect to bind the Float type

    1.1K10编辑于 2024-08-16
  • 来自专栏信数据得永生

    SqlAlchemy 2.0 中文文档(二十八)

    其中一个例子是 asyncpg 驱动程序提供的.set_type_codec()方法。 指定的方言必须是支持 asyncio 的方言,例如 asyncpg。 2.0.10 版的新功能。 其中一个例子是 asyncpg 驱动程序提供的 .set_type_codec() 方法。 一个这样的例子是 asyncpg 驱动程序提供的.set_type_codec()方法。 指定的方言必须是一个 asyncio 兼容的方言,如 asyncpg。 版本 1.4 中的新功能。

    1.1K10编辑于 2024-06-26
  • Chutes Validator 部署全流程教程(完整详细版)

    from-literal="username=chutes" \ --from-literal="password=[Password]" \ --from-literal="url=postgresql+asyncpg

    22910编辑于 2025-10-20
  • 来自专栏网络安全技术点滴分享

    Databricks AI 开发套件 - 为AI驱动的开发赋能

    解析主机名以解决 macOS DNS 问题 # 确保 URL 使用同步驱动进行迁移 url = url.replace('postgresql+asyncpg://', 'postgresql

    14810编辑于 2026-02-23
  • 来自专栏张善友的专栏

    Aspire 13:从.NET 编排工具到真正的多语言云原生应用平台

    ,而 Python 的 SQLAlchemy 或 asyncpg 库则期望标准的 URI 格式(postgresql://...)。 数据库连接属性注入示例(PostgreSQL) 环境变量名 示例值 适用场景 _URI postgresql://user:pass@localhost:5432/db Python (SQLAlchemy, asyncpg

    31410编辑于 2025-12-18
领券