messense 最近的时间轴更新 messense 最近的时间轴更新
Working remotely seems fine.
121 天前
Feels terrible.
121 天前
@messense Actually, logging is hard to do it right.
145 天前
Logging is hard.
145 天前
Feeling like that something is missing.
2014-05-07 17:22:36 +08:00
 ONLINE |
messenseBig brother is watching you. BosonData V2EX 第 14379 号会员，加入于 2011-12-08 21:48:06 +08:00，今日活跃度排名 3917
 46  |
messense
http://messense.me
Shanghai China
messense
messense
messense
messense
messense 最近回复了
39 天前 回复了 resolvewang 创建的主题 › 问与答 › aiohttp 怎么复用连接池 |
 |
一般来说不需要手动 close event loop
39 天前 回复了 resolvewang 创建的主题 › 问与答 › aiohttp 怎么复用连接池 |
|
Python 3.6 以后已经不推荐传递 event loop 了，需要用到 event loop 的时候调用 asyncio.get_event_loop() 就好了。
39 天前 回复了 resolvewang 创建的主题 › 问与答 › aiohttp 怎么复用连接池 |
|
按道理说会自动关闭连接，不清楚 aiomysql 的具体实现细节。
ef tearDown(self):
self.loop.close()
del self.loop
你 tearDown 里面把 loop close 了。。。
ef tearDown(self):
self.loop.close()
del self.loop
你 tearDown 里面把 loop close 了。。。
40 天前 回复了 resolvewang 创建的主题 › 问与答 › aiohttp 怎么复用连接池 |
|
aiomysql.create_pool 需要 await 吧？没有 await 它返回的是个 coroutine，试试：
self.pool = self.loop.run_until_complete(aiomysql.create_pool(...))
self.pool = self.loop.run_until_complete(aiomysql.create_pool(...))
40 天前 回复了 resolvewang 创建的主题 › 问与答 › aiohttp 怎么复用连接池 |
|
把 pool 放到 main 里面？
import aiomysql
import asyncio
async def select(pool, sql):
async with pool.acquire() as conn:
async with conn.cursor() as cur:
await cur.execute(sql)
r = await cur.fetchone()
print(r)
async def insert(pool, sql):
async with pool.acquire() as conn:
async with conn.cursor() as cur:
await cur.execute(sql)
await conn.commit()
async def main(loop):
pool = await aiomysql.create_pool(host='127.0.0.1', port=3306,
user='root', password='123456',
db='test', loop=loop)
c1 = select(pool, sql='select * from minifw')
c2 = insert(pool, sql="insert into minifw (name) values ('hello')")
tasks = [
asyncio.ensure_future(c1),
asyncio.ensure_future(c2)
]
return await asyncio.gather(*tasks)
if __name__ == '__main__':
cur_loop = asyncio.get_event_loop()
cur_loop.run_until_complete(main(cur_loop))
import aiomysql
import asyncio
async def select(pool, sql):
async with pool.acquire() as conn:
async with conn.cursor() as cur:
await cur.execute(sql)
r = await cur.fetchone()
print(r)
async def insert(pool, sql):
async with pool.acquire() as conn:
async with conn.cursor() as cur:
await cur.execute(sql)
await conn.commit()
async def main(loop):
pool = await aiomysql.create_pool(host='127.0.0.1', port=3306,
user='root', password='123456',
db='test', loop=loop)
c1 = select(pool, sql='select * from minifw')
c2 = insert(pool, sql="insert into minifw (name) values ('hello')")
tasks = [
asyncio.ensure_future(c1),
asyncio.ensure_future(c2)
]
return await asyncio.gather(*tasks)
if __name__ == '__main__':
cur_loop = asyncio.get_event_loop()
cur_loop.run_until_complete(main(cur_loop))
76 天前 回复了 cxz 创建的主题 › Python › 2017 年 5 月的现在，还有什么理由不使用 Python 3？ |
|
79 天前 回复了 zhangwb2008 创建的主题 › macOS › [VANILLA] Hide menu bar icons on your Mac |
|
88 天前 回复了 sadhen 创建的主题 › Python › 几乎所有的同事都不支持用 python3 哎 |
|
公司最主要的项目已经在使用 Python 3.6 了。
119 天前 回复了 chztv 创建的主题 › macOS › Setapp 可以继续免费用了，发邀请了！ |
|
