https://github.com/aio-libs The set of asyncio-based libraries built with high quality
i am running into issues on chia
maybe caused by some of this libs
Traceback (most recent call last):
File "/usr/lib/python3.7/asyncio/sslproto.py", line 526, in data_received
ssldata, appdata = self._sslpipe.feed_ssldata(data)
File "/usr/lib/python3.7/asyncio/sslproto.py", line 207, in feed_ssldata
self._sslobj.unwrap()
File "/usr/lib/python3.7/ssl.py", line 767, in unwrap
return self._sslobj.shutdown()
File "/usr/lib/python3.7/asyncio/sslproto.py", line 526, in data_received
ssldata, appdata = self._sslpipe.feed_ssldata(data)
File "/usr/lib/python3.7/asyncio/sslproto.py", line 207, in feed_ssldata
self._sslobj.unwrap()
File "/usr/lib/python3.7/ssl.py", line 767, in unwrap
return self._sslobj.shutdown()
python 3.7.3 on debian buster
Hi guys, I'm testing
janus queue to communicate an async process with a sync one, the problem is that at some point the sync process raises exceptions. how to handled them? import asyncio
import janus
def threaded(sync_q):
for i in range(100):
raise Exception('Some custom Exception')
sync_q.put(i)
sync_q.join()
async def async_coro(async_q):
for i in range(100):
val = await async_q.get()
assert val == i
async_q.task_done()
async def main():
queue = janus.Queue()
loop = asyncio.get_running_loop()
fut = loop.run_in_executor(None, threaded, queue.sync_q)
await async_coro(queue.async_q)
await fut
queue.close()
await queue.wait_closed()
asyncio.run(main())
you probably want?
await asyncio.gather(async_coro(queue.async_q), asyncio.to_thread(threaded, queue.sync_q))
@grubberr: I've never had much luck with pytest-aiohttp - I use:
import pytest
from aiohttp import test_utils
pytestmark = pytest.mark.asyncio
@contextlib.asynccontextmanager
async def aiohttp_client(app):
async with test_utils.TestClient(test_utils.TestServer(app)) as client:
yield client
async def test_1():
app = web.Application()
...
async with aiohttp_client(app) as client:
...
you didn't include a traceback or error message with your paste
2 replies
I have a question I use the library aioodbc
when i use yield for my cursor (that create async_generator)
i need to use on my second function that consumes this generator it = await cursor.__anext_()
otherwise, it's doesn't work , my question is why? and if i have a way to avoid this
this my code
import asyncio
import aioodbc
async def run_query(query='SELECT 42 AS age;'):
dsn = 'Driver=SQLite;Database=sqlite.db'
async with aioodbc.create_pool(dsn=dsn) as pool:
async with pool.acquire() as conn:
async with conn.cursor() as cur:
await cur.execute(quey)
yield cur
async def main(query):
cursor = run_query(qury)
it = await cursor.__anext_()
async for row in it:
print(row)
if __name__ == '__main__':
asyncio.run(main(query="select 1 as blah")
Ben621 (Ben621):
import asyncio
import aioodbc
async def run_query(query="SELECT 42 AS age;"):
dsn = "Driver=SQLite;Database=sqlite.db"
async with aioodbc.create_pool(
dsn=dsn
) as pool, pool.acquire() as conn, conn.cursor() as cur, cur.execute(quey):
return list(cur)
async def main(query):
for row in await run_query():
print(row)
if __name__ == "__main__":
asyncio.run(main(query="select 1 as blah"))
:point_up: Edit: Ben621 (Ben621):
import asyncio
import aioodbc
async def run_query(query="SELECT 42 AS age;"):
dsn = "Driver=SQLite;Database=sqlite.db"
async with aioodbc.create_pool(
dsn=dsn
) as pool, pool.acquire() as conn, conn.cursor() as cur, cur.execute(quey):
async for v in cur:
yield v
async def main(query):
async with async_generator.aclosing(run_query()) as it:
async for row in it:
print(row)
if __name__ == "__main__":
asyncio.run(main(query="select 1 as blah"))
@Ben621 fixed the paste
this code work
need to await
need to await
cur.execute(quey)import asyncio
import aioodbc
import async_generator
async def run_query(query="SELECT 42 AS age;"):
dsn = "Driver=SQLite;Database=sqlite.db"
async with aioodbc.create_pool(
dsn=dsn
) as pool, pool.acquire() as conn, conn.cursor() as cur:
await cur.execute(quey)
async for v in cur:
yield v
async def main(query):
async with async_generator.aclosing(run_query()) as it:
async for row in it:
print(row)
if __name__ == "__main__":
asyncio.run(main(query="select 1 as blah"))
https://github.com/python-trio/async_generator is run by the trio team, it's just not needed any changes
@graingert:matrix.org
I very appreciate your help
I have a question about my code.
if I use also the for loop inside my function
my question is why I need for loop inside my function and on the other function ? that was i want to use
and that why i was needed to use
i think i missing something
I very appreciate your help
I have a question about my code.
if I use also the for loop inside my function
run_query like you did my code workmy question is why I need for loop inside my function and on the other function ? that was i want to use
yield on the cursor ,and that why i was needed to use
it = await cursor.__anext_()i think i missing something
So you need aclosing and async for yield
@graingert:matrix.org
sorry I don't understand, why i need the loop in the run_query
instead only to yield the cursor
that doesn't answer
what i'm missing
if I modify your code
async def main(query):
async with async_generator.aclosing(run_query()) as it:
async for row in it:
print(row)as
async def main(query):
async for row in run_query(query=query):
print(row)so why i need thisasync with async_generator.aclosing(run_query()) as it:
btw i'm using python 3.8
Normally you'd pass your pool into run_query though
I'm sending a 4OPTIONS /call/SetCurrentScene HTTP/1.1\r\n (logged out from sniffer), there is maybe something wrong on this request?
Error handling request
Traceback (most recent call last):
File "/usr/lib/python3/dist-packages/aiohttp/web_protocol.py", line 314, in data_received
messages, upgraded, tail = self._request_parser.feed_data(data)
File "aiohttp/_http_parser.pyx", line 546, in aiohttp._http_parser.HttpParser.feed_data
aiohttp.http_exceptions.BadStatusLine: 400, message="Bad status line 'invalid HTTP method'"
Hey! I'm very new to aiohttp and python in general but I cobbled together an app using openapi. Everything is working but it seems that all the requests are only getting fulfilled by a single thread. Is there some sort of config/option that I need to pass in to app.run(port=8080) (based on this ) to ensure multiple threads work to fulfill requests?
2 replies
Show your code? Are you performing blocking IO @tray2100
1 reply
Hi, when packaging aiohttp for openSUSE, I got few tests failing on
RuntimeError: Event loop is closed https://da.gd/g1oD Any idea, what’s wrong?