- Java锁的逻辑(结合对象头和ObjectMonitor)
- 还在用饼状图?来瞧瞧这些炫酷的百分比可视化新图形(附代码实现)⛵
- 自动注册实体类到EntityFrameworkCore上下文,并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
单一模式运行Celery在官方文档中已经贴出范例代码,这里我们不过多介绍.
在使用Flask编写大型项目时,使用工厂模式的好处显而易见。因在Celery4.x以上版本已经抛弃了init_app方法,所以我们传统的在create_app中初始化并传入app对象的方式已经不可用了。我们改变方式在create_app中直接创建Celery对象就会导致循环导入问题,该如何解决呢?下面我们来一步步操作.
1、首先贴出我的项目结构:
简单介绍一下项目结构(重点说一下Celery组成):
apis:项目接口存放文件夹 。
apps:Flask项目传统文件夹,不在赘述 。
---admin:模型文件夹 。
---decorators.py:自定义装饰器 。
---tasks.py:Celery任务文件,存放所有调度执行任务 。
ext:第三方扩展文件夹,创建第三方扩展对象。例如数据库、api、缓存、跨域等等 。
---celery.py:Celery主文件,创建celery对象,后期引用@celery.task()主要在这 。
migrations:数据库迁移等文件夹 。
static:静态文件文件夹 。
templates:模版文件夹 。
app.py:项目主启动文件 。
celery_settings.py:Celery配置文件 。
settings.py:项目主配置文件 。
2、实现步骤 。
1.下载Celery 。
pip install celery
2.编写celery配置 。
broker_url = 'redis://127.0.0.1:6379/0' result_backend = 'redis://127.0.0.1:6379/0' task_serializer = 'json' result_serializer = 'json' accept_content = ['json'] broker_connection_retry_on_startup = True
3.生成Celery对象 。
在celery.py中编写:
def create_celery(app=None): celery = Celery(app.import_name, backend=broker_url, broker=result_backend) celery.conf.update(app.config) celery.config_from_object('celery_settings') class ContextTask(celery.Task): def __call__(self, *args, **kwargs): with app.app_context(): return self.run(*args, **kwargs) celery.Task = ContextTask return celery
4.编写任务 。
最后我们就可以在tasks.py中编写调度任务 。
celery = create_celery(create_app()) @celery.task() def insert_sql(): for i in range(10): print(i) time.sleep(1)
然后我们在需要执行调度任务的代码处增加启动代码:
insert_sql.delay()
5.启动celery 。
最后不要忘记启动celery,然后就可以在执行到启动任务代码时,执行异步任务.
。
以上就是我们如何在Flask工厂模式中使用Celery范例了.
新手上路,如有疏漏错误,还请各位大佬不吝赐教.
最后此篇关于Flask工厂模式蓝图使用Celery实例【亲测可用,已应用于项目中】的文章就讲到这里了,如果你想了解更多关于Flask工厂模式蓝图使用Celery实例【亲测可用,已应用于项目中】的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
如何检测当前网络中计算机是否已连接/可用。 当然,它有多种用途,但我主要关心的是我的应用程序使用位于特定计算机中的资源,如果这些资源不可用,它甚至不会尝试连接,而是使用本地资源。 最佳答案 您可以尝试
雅虎建议load scripts at the bottom of an HTML pages出于性能原因。我使用遵守规则的 HTML5 Boilerplate。 这种方法的问题是 jQuery 也是
我有一个场景,我需要只向管理员而不是普通用户展示一个组件。 说, // This component should be rendered for public users.
我有一个数组,比方说 ["a","b","c"],我想把它变成一个对象,它以数组值作为键和一个默认值我可以设置。因此,如果默认值为 true,我希望我的输出为 {a:true, b:true, c:t
我假设在函数中创建一个新的 PS-Drive 会使该驱动器只能在该函数中访问。 如何通过从该函数可访问的 MAIN 调用函数来创建 PS 驱动器? $temproraryPSDriveName =
您会推荐哪些 .net 控制库作为企业必备的? 可以免费/非免费 至少应该包含一个真正强大的Datagrid Ajax 功能 有没有可用的比较? 最佳答案 我用过 Telerik ASP.NET控制之
假设我有一些像这样的 html: Hello World Javascript代码: var fooBar = document.getElementById('fooBar'); fooBar.
开始实现 camera plugin 时出现以下错误在我的 flutter 应用程序上: [VERBOSE-2:dart_error.cc(16)] Unhandled exception:
我想知道应该在哪里正确放置 countA,因为我希望将计数添加到所做的每个按钮中。开头的“count”变量用于制作新按钮,“countA”是我试图声明的计数,但它无法编译。这是我的代码片段:我的问题再
在python帮助文档中我经常看到带有函数名和命名参数的签名行,然后你会看到**kwarg(关键字参数)。 list? 打印到帮助文档字符串: Init signature: list(self, /
我是 UWP 的新手,想知道“Flyout”、“ContextFlyout”和“Popup”之间的区别。另外,我想知道“AppBar”和“CommandBar”之间的区别。我相信这些是容纳菜单或菜单项
我想显示可用的 Wifi 设备列表。这是我的代码,我不明白这里有什么错误: wifi = (WifiManager) getSystemService(Context.WIFI_SERVICE); i
这是我的代码: Random = function(name) { this.name = name; this.addSomething = function(a, b) {
我希望我的按钮持续动画直到用户触摸它,这是代码 func animate() { UIView.animateWithDuration(1, animations: { () -> Void
我正在为我正在参加的类(class)制作一个 HTTP 服务器作为项目,一周来我一直在尝试寻找解决方案。我有一个 DataInputStream,我需要等待客户端向我发送 http 请求,由于连接保持
我想创建一个 bash 脚本来检查我的 Linux 服务器中的哪些端口已关闭且未在特定范围(端口范围 (3000-3010))中使用。 打印输出只需1个端口,如果将输出保存为变量或保存在同一个文件中,
我写了一个我认为是最小的自定义设备来测试我对 QOM 和 QEMU 的总体理解。以下是省略注释的相关代码。不幸的是,当我启动 guest 并将我的设备名称作为命令行参数传递时,它无法找到我的设备并退出
调用Opencv函数时,通常会提供一个常量给函数调用,如: im_hsv = cv2.cvtColor(im, cv2.COLOR_BGR2HSV) 虽然我找不到对所有可用常量的引用。 Opencv
C++ 于 1998 年正式标准化,但我们能在多久以前找到一个名为 string 的类,它看起来像 C++2003 中的 std::string预标准 C++ 实现? 我问是因为 CString 作为
是否有一个官方的(或可能没有)git 命令列表,--porcelain 选项可用?或者我应该在 the porcelain commands list 中手动查看它们中的每一个吗? ? 我已经设法用谷
我是一名优秀的程序员,十分优秀!