fix: backfill_affiliations 容器内连接 — 从 DATABASE_URL 推导 sync URL(容器只有 async 驱动 env,DATABASE_URL_SYNC 会落到 localhost 默认值连不上 postgres 服务)
This commit is contained in:
@@ -32,7 +32,10 @@ _VACUUM_EVERY = 10 # 每 10 批执行一次 VACUUM,回收死元组空间,
|
|||||||
|
|
||||||
async def main() -> None:
|
async def main() -> None:
|
||||||
settings = Settings()
|
settings = Settings()
|
||||||
conn = await asyncpg.connect(settings.DATABASE_URL_SYNC)
|
# 容器里只有 DATABASE_URL(async 驱动),DATABASE_URL_SYNC 没设会落到 localhost 默认值
|
||||||
|
# → 从 DATABASE_URL 推导:去掉 SQLAlchemy 驱动名即是 asyncpg 可用的 URL
|
||||||
|
sync_url = settings.DATABASE_URL.replace("+asyncpg", "")
|
||||||
|
conn = await asyncpg.connect(sync_url)
|
||||||
try:
|
try:
|
||||||
await conn.execute("SET max_parallel_workers_per_gather = 0")
|
await conn.execute("SET max_parallel_workers_per_gather = 0")
|
||||||
remaining = await conn.fetchval(
|
remaining = await conn.fetchval(
|
||||||
|
|||||||
Reference in New Issue
Block a user