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

文章/答案/技术大牛

发布

1回答

python、celery、tornado、python-asyncio、coroutine

有一个旧的库现在已经死了，所以我想摆脱它，并将celery更新到新版本。即使芹菜任务已经是异步的，我也需要能够使用协程。我需要协程，因为目前我们有很多使用异步调用编写的任务，这要归功于tornado-celery库和某种黑魔法。正因为如此，我需要一种在芹菜任务中

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

2回答

asyncio和协程vs任务队列

python、task、python-asyncio

我一直在阅读有关python3中的asyncio模块，以及更广泛的关于python中的协程的内容，但我不明白asyncio是什么让asyncio成为如此伟大的工具。我有一种感觉，使用协程可以做的所有事情，都可以通过使用基于多处理模块(例如芹菜)的任务队列来做得更好。有没有协程比任务队列更好的用例？

浏览 4提问于2015-12-23得票数 26

1回答

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

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

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

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

1回答

消息的并发处理(Python)

python、multithreading、concurrency

问题是:我可以使用什么库或框架来实现此体系结构？据我所知，Python Tornado有很好的基准测试，但这里我不需要web框架，只需要一个可以提供消息处理器并发运行的工具。

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

1回答

如何通过搁置库使用dill库进行对象序列化

python、pickle、coroutine、shelve、dill

我正在使用PyMemoize库缓存协程。我装饰了协程，但是当Python调用它时，我得到：之所以会发生这种情况，是因为PyMemoize内部试图将协程存储在为此，它使用shelve.Shelf，而后者又使用pickle。问题是，由于未知的原因，pickle不支持酸洗协程。我尝试过用di

浏览 3提问于2018-10-22得票数 4

1回答

Python中的协程与Lua中的协程相比如何？

python、asynchronous、lua、async-await、coroutine

对Lua中的协程的支持是由提供的，主要是create、resume和yield。开发人员将这些协程描述为。在Python中也可以使用协程，可以使用 (和)，也可以使用3.5版中添加的。Python中的协程与Lua中的协程相比如何？它们也是堆叠的、一流的和不对称的吗？为什么Python需要这么

浏览 57提问于2016-09-24得票数 16

2回答

在Python中使用协程进行并行编程

python、parallel-processing、coroutine、concurrency

协程是简化并发编程的一个很好的范例。大多数情况下，并发任务很容易并行化。在语言中，使用goroutines执行并行任务是很容易的。有没有办法在Python中做同样的事情，例如使用协程来创建进程并同步它们？

浏览 5提问于2011-06-30得票数 5

回答已采纳

1回答

在asyncio中，"yield from“语法是做什么的?它与"await”有什么不同？

python、async-await、generator、python-asyncio、coroutine

有一个问题询问了yield from语法和的使用，但这两个问题都深入讨论了不同的主题，并没有真正简明地解释底层代码以及它是如何适应异步的。

浏览 2提问于2017-05-30得票数 52

回答已采纳

1回答

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

go、kotlin、coroutine、goroutine、kotlin-coroutines

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

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

回答已采纳

1回答

Asyncio任务与协程

python-asyncio

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

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

回答已采纳

2回答

协程如何提高性能

python、coroutine

我已经看到很多关于python中的协程的演讲和文章。它们被认为是“微线程”，我听说它们可以提高性能。协程如何提高性能？到目前为止，我看到的是它们是单线程的，并且是按顺序执行的。

浏览 0提问于2011-07-05得票数 16

回答已采纳

0回答

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

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

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

浏览 244提问于2023-04-03

1回答

批处理的Python异步协程

python、asynchronous、semaphore、coroutine、gather

我想分批处理协程，如下所示： import asyncio print(f"Start Task {i}") await asyncio.gather(*[test(i) for i in range(100)]) 没有像预期的那样处理协程:协

浏览 45提问于2021-06-26得票数 6

1回答

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

python、asynchronous、twisted、python-asyncio、coroutine

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

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

1回答

在Python语言中等待vs asyncio.run()

python、async-await、coroutine

在Python语言中，await使用协程和使用asyncio.run()的实际区别是什么？它们似乎都在运行协程，我能看到的唯一区别是await只能在协程中使用。

浏览 12提问于2020-11-23得票数 7

回答已采纳

4回答

在Flask中创建异步任务

python、asynchronous、flask

我有一个特别的任务，它调用第三方API，该任务可能需要几分钟才能完成。我想进行这个调用(实际上是一系列调用)，并让它运行。同时将控制权返回给Flask。这是我唯一需要Flask异步运行的任务，我想要一些关于如何最好地实现它的建议。我看过Twisted和Klein，但我不确定它们是否过度杀伤力，因为也许线程就足够了。或许芹菜是个不错的选择？

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

回答已采纳

1回答

使用asyncio编写的程序运行时间与同步版本相同

python、python-asyncio、coroutine

我开始学习python asyncio模块。我正在写一个基本的程序，它基本上是等待一段时间，然后打印结果。我编写了上面给出的协程，并创建了一些任务。tasks = (asyncio.create_task(say_helloworld(i)) for i in range(10)) for task in tasks:最后，我运行了包装器<em

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

2回答

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

java、multithreading、kotlin、asynchronous

据我所知，kotlin协程--这是一个带有预初始化线程池的状态机。我们有一个工作线程池和一个io线程池。对我来说，这只是一个多线程编程。如果我们向协程发送阻塞代码，线程将被阻塞。如果我们使用async方法(来自默认协程库)，它会给我们一种异步工作的错觉，但这只是将“job”发送到另一个线程。如果我们使用带有协程的async io，另一个问题。据我所知，.NET已经重建了他们的异步api (作为IO

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

1回答

使用Python-Asyncio取消指定时限后的输入

python-3.x、python-asyncio

你好，我正在尝试使用异步来获取输入，如果给定，则继续，如果未给定，则取消任务并使用默认输入。with suppress(asyncio.CancelledError):这是一个无限循环，给用户5秒的时间来提供输入，如果用户没有提供任何输入，则使用默认的输入

浏览 16提问于2019-08-19得票数 0

回答已采纳

1回答

如何产生多个协程，然后加入它们？

c++、join、yield、coroutine、asio

我使用的是boost::asio，我的代码如下： async_wait(other_1 and other_2);} 我希望同时产生2个或更多的协程我尝试过协程TS，但g++还不支持。我如何才能做到这一点？

浏览 2提问于2020-02-24得票数 1

点击加载更多