0
"runquery"함수는 프로그램의 다른 부분에서 호출됩니다. 이 경우에는 쿼리 문에서 "준비"를 사용하지 않습니다. "prepared statement already exists"에 대한 다른 질문을 모두 읽었으며 "DEALLOCATE ALL"도 시도했습니다. 그러나 그 반대의 오류가 발생합니다 : 아래의 오류가 준비된 진술이 이미 존재하는 동안 불평하지만, 모든 결과는 그것이 존재하지 않는다는 불만을 나타냅니다.asyncpg.exceptions.DuplicatePreparedStatementError : prepared statement "stmt_5"가 이미 있습니다.
이것은 asyncpg를 사용하여이 유형의 프로그램을 실행하려는 나의 첫 번째 시도입니다. 나는 psycopg2를 사용하는 동안 이전에는 이것을 가지고 있지 않았다. psycopg2로 돌아 가야합니까? 아래 그림과 같이 많은 쿼리 후
는 RUNQUERY는 오류보고로 끝나는 :
이Could not complete query "select uuid from wos_2017_1.combined_name where combined_name = 'xxxxxxx';"
Traceback (most recent call last):
File "update2017.py", line 1206, in runquery
result = await con.fetch(query)
File "/usr/lib/python3/dist-packages/asyncpg/connection.py", line 268, in fetch
stmt = await self._get_statement(query, timeout)
File "/usr/lib/python3/dist-packages/asyncpg/connection.py", line 212, in _get_statement
state = await protocol.prepare(None, query, timeout)
File "asyncpg/protocol/protocol.pyx", line 140, in prepare (asyncpg/protocol/protocol.c:55210)
File "/usr/lib/python3.5/asyncio/futures.py", line 380, in __iter__
yield self # This tells Task to wait for completion.
File "/usr/lib/python3.5/asyncio/tasks.py", line 304, in _wakeup
future.result()
File "/usr/lib/python3.5/asyncio/futures.py", line 293, in result
raise self._exception
asyncpg.exceptions.DuplicatePreparedStatementError: prepared statement "stmt_7" already exists
$ grep -c INSERT /tmp/y.log
1006
$ grep -c SELECT /tmp/y.log
1364
$ grep -ci UPDATE /tmp/y.log
1044
$ grep -ci delete /tmp/y.log
2548
import asyncio,asyncpg
async def make_pool():
"""Create asyncpg connection pool to database"""
pool = await asyncpg.create_pool(database='wos',
host = 'localhost',
user = 'xx',
password='xxxxxx',
port=5432,
min_size=10,
max_size=50)
return pool
async def get_con(pool):
con = await pool.acquire()
return con
async def runquery(query):
con = await get_con(pool)
try:
if query.startswith('delete from') or query.startswith('insert'):
result = await con.execute(query)
else:
result = await con.fetch(query)
except:
print('Could not complete query "{}"'.format(query))
print(traceback.format_exc())
result = None
exit(1)
finally:
await pool.release(con)
return result, success