python-asyncio

    3热度

    1回答

    我正在阅读asyncio程序包中Protocol和Transport类的文档。具体来说: 当继承协议类时,建议您重写某些方法。这些方法是回调函数:它们将在某些事件中由传输器调用(例如,在收到某些数据时)。除非您正在实施交通工具,否则您不应该自己拨打电话,。 着重强调 因此,在原则上,它应该是可以实现的传输,但是...... 传输是通过ASYNCIO以各种抽象类提供各种沟通渠道。你通常不会自己实例化

    3热度

    1回答

    如何在run_in_executor调用的run_long_thing()函数中引发异常? 它看起来像被吞咽。我不需要阻塞代码中的函数结果。它基本上是一个射后不理功能,但我仍然需要捕获异常,如果有任何... import asyncio import time def fire_and_forget(task, *args, **kwargs): loop = asyncio.g

    1热度

    1回答

    例(以下问题):?? import asyncio import typing as t from aiokafka import AIOKafkaConsumer class KafkaSimpleClient: ... async def receive(self, topic: str) -> ???: bootstrap_servers =

    0热度

    1回答

    我正在使用Asyncio进行网络编程,在python中编写应用程序。我有类似的代码太: try: data = await self._reader.readexactly(10000) # Code that uses data except IncompleteReadError as e: data = e.parial # More code

    1热度

    1回答

    一致我只想运行一个简单的测试示例,但我得到下面的错误。我该如何解决? import asyncio import uvloop import concurrent.futures import time asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) async def do_some_work(x): whi

    1热度

    1回答

    我想程序从龙卷风转换为ASYNCIO的第一步是使用实际ASYNCIO事件循环作为described here。 此应用程序在嵌入式Linux机器上运行,我使用通过sysfs/gpio subsystem的GPIO以及我正在等待中断的某些GPIO。我能直接在此整合到龙卷风IOLoop做: # Register with the queue self.io_loop.add_handler(

    1热度

    1回答

    我想我得到这个错误是因为我的代码调用asyncio.get_event_loop().run_until_complete(foo())两次。一旦从foo()第二次从函数调用foo()。那么我的问题是:为什么这会成为一个问题呢?为什么我更关心这个循环是否正在运行? 有这个问题,我认为它,做编辑,遮蔽它(有些人喜欢遵守规则不理解他们,从而从标题删除“非法”二字)。不幸的是,这造成了混乱。 我对提出错

    -2热度

    1回答

    我有一个小问题,我的Discord bot是用Python编写的,而且我不断收到错误。这是我的机器人的代码: import discord import asyncio client = discord.Client() @client.event async def on_ready(): print('Logged in as') print(client.us

    1热度

    1回答

    文档说重复使用ClientSession: 不要为每个请求创建会话。最有可能你需要一个会话,每个 应用程序完全执行所有请求。 会话中包含连接池,连接重用和keepalive(默认情况下都处于打开状态)可能会加速整体性能。 1 但是在文档中似乎没有关于如何做到这一点的任何解释?有一个例子可能是相关的,但它并没有说明如何在其他地方重新使用该池:http://aiohttp.readthedocs.io

    2热度

    1回答

    我与中信高科工作后,但我有点卡住了。我打电话给3个不同的API,每个都有自己的响应时间。 我想创建一个超时功能,它为每个任务返回一个可接受的时间。但是如果时间任务在可接受的时间内没有完成,我想返回部分数据,因为我不需要一个完整的数据集,速度更关注。 不过,我想保持未完成的任务工作,直到完成(即请求API数据插入到一个Postgres数据库。 我想知道,如果我们能做到这一点,而无需使用某种调度到保持