1回答
我正在运行一个程序，该程序从rest api发出三个不同的请求。data、indicator、request函数都使用我制作的包装器从BitMEX的api中获取数据。我已经使用asyncio来尝试加速这个过程，这样当我在等待来自前一个请求的响应时，它可以开始进行另一个响应。 然而，由于某些原因，我的异步版本并没有运行得更快。下面是异步版本： import time
f
浏览 9提问于2019-06-16得票数 1
回答已采纳
1回答
我正在尝试离开线程，开始使用异步。我试着写一些简单的东西，这样我就可以更好地使用异步；由于某些原因，我的异步代码并不是异步的。 main() 02468异步代码import random await asynci
浏览 0提问于2019-07-23得票数 1
1回答
我想做一个实时人脸识别器与蔚蓝认知服务的脸api。但是api调用需要很长时间。我能做什么?
我用简单的while循环编写了我的代码。抓取一个框架并检测该帧中的面孔。我应该使用什么概念？我看到了类似异步的东西，我应该用它吗？
浏览 0提问于2019-08-13得票数 1
回答已采纳
1回答
我的代码如下： loop = asyncio.new_event_loop()
asyncio.set_event_loop(loop)
浏览 0提问于2018-05-02得票数 3
回答已采纳
我一直在协同线的末尾得到asyncio.exceptions.CancelledError，尽管据我理解，一切都是正确的等待，所有的队列都被正确地使用和连接。request_queueCreate 打开新会话，创建一个用于处理API请求的队列和一个用于API响应的第二个队列。生成响应并将它们放到另一个队列中，创建一个单独的responsesWait，它使用processedCan
浏览 8提问于2022-01-13得票数 0
2回答
我正在尝试从数据库中检索数据，以便在api上下文中使用。但是，我注意到conn.close()的执行时间相对较长(在这个上下文中，conn是来自mysql连接池的连接)。由于关闭连接并不会阻塞api返回数据的能力，因此我想我可以使用asyncio来关闭异步连接，这样它就不会阻塞返回的数据。(stuff)) 然而，尽管asyncio.ensure_future(close(conn))没有阻塞(我放入了计时语句，以查看所有操作花费了多长时间，并且此命令前
浏览 26提问于2020-04-17得票数 0
我想用很小的固定时间来触发API请求，比如时钟工作，假设是0.1s，我们将使用aiohttp假设api的速率限制为10次/秒。当结果返回时，我想对其执行几个检查，如果成功，将提前终止该功能。这意味着它没有比连续运行它提供任何好处。有人能指出我可以在哪里修改代码以得到想要的行为吗？我还想在可能的情况下优化它，因为GET请求总是请求同一个端点，并且可能会在那里进行优化，例如共享会话对象。谢谢import datetimeimport
浏览 0提问于2021-06-04得票数 0
回答已采纳
我正在编写一个脚本，从电报中下载所有保存的消息，使用Telethon库与telegram的API交互。from telethon import TelegramClientapi_hash = '' #hashvalue
client = TelegramClient(
浏览 9提问于2022-03-23得票数 0
回答已采纳
2回答
：如何在每个任务之间创建延迟
、、、、
问题，我正试图解决：--我向服务器发出了许多api请求。我试图在异步api调用之间创建延迟，以遵守服务器的速率限制策略。我想要它做的事情，，我希望它的行为像这样：
asyncio.sleep()问题:当我在代码中引入或time.sleep()时，它仍然几乎立即发出了请求。它似
浏览 7提问于2021-07-05得票数 4
回答已采纳
我有一个Flink应用程序，它使用带有多个分区的Kafka主题上的传入消息，然后进行一些处理，然后将它们发送到通过HTTP发送到外部服务的接收器。当Http接收器无法发送输出消息时，抛出一个异常。这将导致根据配置的重新启动策略重新启动任务和作业。最终，下游服务将恢复，系统将继续在中断的地方运行。让Sink睡眠并在失败时重新尝试；它可以持续地这样做，直到下游服务恢复为止。
根据我的理解和我的PoC，我将完全失去-至少一次保证，因为接收器本身是外部状态。Which建立一个TwoPhaseCommitSinkFunction，或者两者都没
浏览 2提问于2021-11-21得票数 0
回答已采纳
下面是一个示例： loop = asyncio.get_event_loop() print("coro2 - we want to get here")
main()
如您所见，第一个协同器首先执行，但第二个协同器不并发运行
浏览 1提问于2020-06-03得票数 7
回答已采纳
下面的内容运行正常，但出于某种原因，请求似乎是同步执行的，而不是异步执行的。async def do_request(query_string): 'query': query_strin
浏览 0提问于2018-03-05得票数 4
回答已采纳
我设法异步获取api请求，但在尝试将其实现到主项目中时收到此错误。这意味着我做错了什么？File "C:\Users\Admin\Desktop\djangoProjects\dguac\Signal.py", line 124, in main Bclient = CryptoXLib.create_binance_client(sigSettings_dict['API_key']
浏览 2提问于2021-05-15得票数 1
我正在尝试从一个api获得一些响应，而我正在使用一个包装器。token = "my token"
浏览 2提问于2019-08-12得票数 3
回答已采纳
1回答
有一个API localhost:8000/api/postdatetime/，它负责更改驱动程序的在线状态。每次驱动程序命中API时，如果返回响应，则驱动程序状态将处于联机状态，否则驱动程序状态将脱机。Drivers need to give the response within every 10 seconds.如果没有来自驱动程序的响应，那么他/她将被自动标记为脱机。为了保持成千上万的驱动程序的在线脱机，使用</e
浏览 13提问于2019-11-04得票数 2
回答已采纳
1回答
我使用的API限制为4个请求/s，我使用asyncio和aiohttp来发出异步http请求。我在使用Windows。
在使用API时，我通常会收到3个状态代码，200、400和429。当看到多个400 s时，4/s问题完全可以处理，但当我收到200并试图使用response.json解决json时，我就开始收到429 s的太多请求。我想弄明白为什么会发生这样的
浏览 10提问于2022-06-13得票数 1
我正在用Python做我的第一步，我有一点挣扎，试图理解为什么我没有预期的结果与这个。以下是我正在努力实现的目标：import aiohttp
async def consume_<e
浏览 2提问于2021-01-31得票数 0
回答已采纳
1回答
消息是短字符串，大约每秒发布一次，因此我们没有考虑性能问题。def subs(url, channel): import zmq.asyncio
浏览 1提问于2020-10-05得票数 2
回答已采纳
我有一个使用api的简单脚本。我创建number_of_user用户。我遍历循环，创建随机用户create_random_user()，对于我创建任务和附加任务循环的每个用户。获得响应后创建async def fetch_user_create的任务为用户登录async def fetch_user_log创建另一个任务，并将其添加到所有任务中。我试着放置等待asyncio.sleep(1) -这是工作，但取决于number_of_user。
目标:等待条件是否可能？或
浏览 5提问于2021-03-30得票数 0
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号