将异步协程作为celery任务运行

文章/答案/技术大牛

发布

1回答

python、async-await、celery、tornado、python-asyncio

我希望能够在我的celery任务中使用异步代码。它适用于异步或龙卷风。我发现，我可以做这样的事情 from tornado.ioloop import IOLoop print('Async IS OKAY:

浏览 49提问于2019-09-03得票数 4

1回答

检测协程是否需要异步循环

python、asynchronous、twisted、python-asyncio、coroutine

我正在编写使用Twisted在用户提供的协程上等待的代码。在一个更简单的例子中，我所需要的就是使用defer.ensureDeferred将协程转换为延迟。但是，如果协程使用asyncio.sleep()，我需要使用asyncio.ensure_future将其包装到异步任务中，该任务将在异步循环中运行，这需要AsyncioSelectorReactor。我希望支持第一种情况，即使

浏览 13提问于2019-08-23得票数 4

1回答

如何使用python协程作为celery任务？

python、celery、tornado、python-asyncio、coroutine

有一个旧的库现在已经死了，所以我想摆脱它，并将celery更新到新版本。任何提示对异步者或龙卷风都有好处。即使芹菜任务已经是异步的，我也需要能够使用协程。我需要协程，因为目前我们有很多使用异步调用编写的任务，这要归功于tornado-<e

浏览 24提问于2019-08-14得票数 2

1回答

python异步任务的最大数量是多少

python、python-asyncio

我正在设计一个应用程序，其中我创建了10000个任务。我有一个协程(查询webservice的异步函数)，我用不同的参数在协程上做了10000次异步create_task。并发运行的任务是否有上限？

浏览 1提问于2020-11-19得票数 1

2回答

为什么kotlin协程被称为异步？

java、multithreading、kotlin、asynchronous

Jetbrains在每一篇关于kotlin的文章中都谈到了异步编程。但我不明白为什么它们被称为异步？据我所知，kotlin协程--这是一个带有预初始化线程池的状态机。如果我们向协程发送阻塞代码，线程将被阻塞。如果我们使用async方法(来自默认协程库)，它会给我们一种异步工作的错觉，但这只是将“job”发送到另一个线程。如果我们使用带有协程的async io，另一个问题。但这是IO

浏览 5提问于2021-09-17得票数 3

1回答

uasyncio parralel (多)线程似乎不工作

python、python-asyncio、micropython

我试着使用两个我想要在同一时间连续执行的例程，但只有第一个例程在运行… 我哪里错了？

浏览 2提问于2020-08-08得票数 0

0回答

测试从常规函数调用python协程(async def)

python-3.x、python-3.5、python-asyncio

假设我有一些异步协程，它获取一些数据并返回它。如下所示： result = await some_io()基本上，这个协程是从协程链中调用的，初始协程是通过创建一个任务来运行的但是，如果出于测试目的，我只想在运行某些文件时以这种方式运行一个协程： if

浏览 4提问于2016-12-21得票数 3

回答已采纳

1回答

Asyncio任务与协程

python-asyncio

阅读异步文档，我意识到我不理解一个非常基本和基本的方面:直接等待协程和当它被包装在任务中时等待相同的协程之间的区别。在文档示例中，对协程在没有等待的情况下按顺序运行，并且当包装在 ..。然而，令我困惑的是，在示例代码中，我到处都在阅读(例如，展示如何使用 )，有许多地方等待(用户定义的)协程(通常在其他一些用户定义的协程的中间)而不被包装在任务中，我想知

浏览 31提问于2019-09-17得票数 17

回答已采纳

2回答

调用子进程时的Python异步请求处理

python、subprocess、tornado、popen

当一个请求进入时，我使用tornado.process.Subprocess执行一个长时间运行的外壳命令。有没有办法在shell命令运行时继续处理新的请求，并在shell命令完成后返回结果。

浏览 1提问于2017-03-29得票数 0

1回答

哪个协程(goroutines和kotlin协程)更快？

go、kotlin、coroutine、goroutine、kotlin-coroutines

Kotlin corutines对于有限状态机和一些任务运行器(例如，默认ForkJoinPool)来说是糖。Go运行时支持“协程”。但是goroutines并不是真正的<

浏览 2提问于2017-10-21得票数 44

回答已采纳

2回答

使用单元测试支持清理Kotlin中的协程用法

android、unit-testing、asynchronous、kotlin、kotlinx.coroutines

一段时间以来，我们正在使用Kotlin，我们目前关注的一件事是使用协程来处理我们想要异步运行的操作。虽然示例用法很清楚，而且很有效，但我在以一种干净的方式将其集成到我们的架构中时遇到了一些问题。当查看针对域的类的方法实现时，其想法是它易于阅读，并且异步功能带来的“噪音”尽可能少。我知道我不能在没有真正使用异步的情况下使用它。这个()看起来很有趣，但我不喜欢调用类为presenter启动上下文的想法，因为这反过来又有一个执行一些异步工作的依赖项。虽然作为</em

浏览 3提问于2017-10-03得票数 2

2回答

Asyncio在循环中等待事件

python、python-asyncio

asyncio.ensure_future(monitor(ts3conn, dbconn)) loop.run_forever() 现在，当我得到任何事件时，检查if语句，如果有True，我必须等待函数或创建新任务我想异步3个功能，1主，侦听所有时间和其他什么将被创建时，有人写消息/加入通道，在此脚本异步仍然不工作，当30个用户加入通道777 (如果777 == int(事件‘’ctid‘)：)，同时有人将加入通道

浏览 39提问于2019-09-01得票数 1

回答已采纳

1回答

消息的并发处理(Python)

python、multithreading、concurrency

我只想把它设计成同时处理传入消息的方式，但还有一个要点:在每次处理结束时，应该将一个答案传递给输出队列，该队列被组织在一个单独的线程中。然后，答案将通过HTTP发送。据我所知，Python Tornado有很好的基准测试，但这里我不需要web框架，只需要一个可以提供消息处理器并发运行的工具。

浏览 1提问于2016-12-05得票数 1

4回答

在Flask中创建异步任务

python、asynchronous、flask

我有一个特别的任务，它调用第三方API，该任务可能需要几分钟才能完成。我想进行这个调用(实际上是一系列调用)，并让它运行。同时将控制权返回给Flask。'application/json', )final_file = audio_class.render_audio() 运行并提供方法返回时要执行的回调这是我唯一需要Flask异步运行的任务，我

浏览 72提问于2015-08-07得票数 128

回答已采纳

2回答

Python Asyncio没有使用asyncio.run_coroutine_threadsafe运行新的协程

python、python-asyncio

1>Python Asyncio没有使用asyncio.run_coroutine_threadsafe运行新的协程。下面是在Mac上执行的代码测试。loop.set_debug(True) 12 当我在不同的执行器上运行时

浏览 0提问于2019-12-22得票数 1

1回答

使用asyncore实现gethostbyaddr()

python、python-2.7、sockets、dns、asyncore

我很享受socket.gethostbyaddr()的乐趣，寻找如何加速一个真正简单的代码，随机生成一些IP地址，并试图解决它们。当找不到主机时，问题就出现了，超时可能会很长(大约10秒...)我想知道是否有可能使用Asyncore做一些等效的事情？这就是我首先尝试做的，但不幸失败了……import socket a = str(random.randint(140,150)) b = str(random.randint(145,15

浏览 32提问于2017-08-01得票数 1

回答已采纳

1回答

Firebase异步任务到协程

android、kotlin、firebase-authentication、kotlin-coroutines

我使用了挂起例程构建器来使Firebase任务从基于异步侦听器的代码转移到基于协程的代码。这是我的suspendcoroutine，通过它我实现了协程行为。awaitTask() 在我们执行一个可能出现空结果的任务之前，一切都运行得很好。就像。 firebase.currentUser?.updateProfile(profileUpdates)?.在这种情况下，应该将什么传递给continuation.resume？

浏览 8提问于2019-03-25得票数 1

回答已采纳

0回答

为什么TencentKona-8 协程池堵塞不执行任何任务？

factory、scheduler、task、线程池、协程

使用了TencentKona-8的协程功能，替换原来的线程池。大概协程池创建如下：2、通过指定scheduler的方式创建ThreadFactory，并创建10个协程的协程池。task.getThreadNamePrefix(), 0).factory(); ExecutorService executorVT = Executors.newFixedThreadPool(

浏览 244提问于2023-04-03

1回答

在Python语言中将Asyncio与for循环一起使用，类似于在Javascript中使用map方法和promise.all

javascript、python、python-3.x、python-asyncio、google-apps

我尝试在Python语言中异步运行for循环，就像在Javascript中使用map方法和promise.all所做的那样。我到处寻找如何做到这一点，但下面的代码仍然在同步运行(一个接一个地做，而不是像promise.all允许的那样，让循环在前一个循环结束时进行其他迭代)。任何帮助都将不胜感激。

浏览 1提问于2019-08-01得票数 0

1回答

负责MVVM中的异步执行

c#、mvvm、task-parallel-library、coroutine

在MVVM中，谁负责异步数据获取？例如，我的视图有5个不同的数据集合要获取，我希望以预定义的顺序异步检索这些数据。出于这个原因，我使用协程和任务。问: VM应该对此负责吗?我的模型/存储库应该定义GetCustomersAsync方法，将查询包装在任务中，还是应该留给VM？

浏览 0提问于2012-06-12得票数 2

回答已采纳

点击加载更多