Oejia 技术栈
首页
应用市场
方案
OE学院
分享
关于
编辑器
登录
Odoo 异步任务队列 task_queue 基于 celery 的使用
admin
on 2022-02-02
### 安装 - pip install celery==4.1.0 - pip install sqlalchemy (如果需要存储任务执行结果的话) - pip install redis (如果使用redis作为消息存储后端) ### 配置 在 odoo 的 conf 配置文件中可用的配置项: ```config # 消息存储后端 celery_broker_url = redis://localhost # redis://:e342dsf342543g5454@localhost # 是否存储任务执行结果 celery_result_backend_db = postgresql://openerp:openerp@localhost/dbname # 默认的队列 celery_default_queue = odoo # 可选队列 celery_queues = queue1, queue2, queue3 ``` ### Worker的运行 参考如下task_worker.py 代码: ```python # coding=utf-8 __import__('pkg_resources').declare_namespace('odoo.addons') import odoo from odoo.cli.shell import Shell args = ['-c', 'xxx.conf'] Shell().init(args) from odoo.addons.task_queue.tasks import * ``` 启动: `celery -A task_worker worker --loglevel=info` 扩展参数: `celery -A task_worker worker -c 1 -n s1@saas --loglevel=info` ### beat心跳的运行 通常为一个beat多个worker 启动: `celery -A task_worker beat --loglevel=info` ### Odoo中使用 ```python from odoo.addons.task_queue.api import Async @Aysnc() @api.model def func(self, a, b): pass @Aysnc(queue='queue1') @api.multi def func1(self, a, b): pass @Aysnc(queue='queue2') @api.one def func2(self, a, b): pass ``` 注意:确保方法的参数均为可序列化的python内置类型 在调用前如果异步任务执行时会引用到刚变动的记录请执行下数据库 commit 使变动确实生效 多进程worker同时跑时可能会出现odoo的事务错误,建议odoo中多使用autocommit=True的模式操作数据库
Information
Odoo 异步任务队列 task_queue 基于 celery 的使用
http://www.oejia.net/article/fe1e80ff03937d356de20bd9490809d0
http://www.oejia.net/raw/fe1e80ff03937d356de20bd9490809d0
admin
on 2022-02-02
Category
Odoo
Related
2023-08-27 :
处理 Error Failed to download metadata for repo ‘appstream‘ Cannot prepare internal mirrorlist
2021-08-31 :
Odoo 商城模块 Oejia_weshop v0.2.4 发布,可融合POS构建线上线下一体化会员系统
2021-12-27 :
商城——预约
2021-04-30 :
微信模块 Oejia_wx v0.6.4 发布,增强模板消息功能,增加hr员工、部门和企业微信的协同
2022-05-30 :
浏览器调用print实现部分打印的两种方法
2016-12-04 :
代码集锦
2016-03-07 :
Nginx 相关积累
2020-05-06 :
OE小程序商城订阅消息通知使用说明
2019-03-08 :
Odoo 菜单美化模块 oejia_menu 常见问题处理
2021-09-25 :
使用微信模块推送公众号模板消息
官方订阅号
关注订阅实时了解我们更多分享
分类
(20)
Django (3)
DjangoX (13)
JS (2)
Nginx (1)
Odoo (134)
Python (1)
YouMd (3)
公告说明 (2)
前端 (2)
后端HTTP (7)
异常处理 (1)
桌面UI (1)
移动开发 (4)
About This Entry
用 VIM 操作 BOM 标记
Odoo PoolError
About This Blog
main index
to find recently
archives
to find all
标签
微信模块发布记录
微信模块
小程序商城
Web
Http
客服系统
审批OA
HTML5
OE商城
Markdown
DjangoX
解析
oeshop
PyQT
服系统
YouPBX
Excel
示例
md
markdown
Python
最近发布
OSError [Errno 5] Input/output error 异常处理
Odoo context 的常见使用示例
Odoo 符合国人菜单导航习惯的后台主题,支持最新的Odoo17、16等版本,支持企业版!
Odoo 官方应用市场开启 Odoo17 应用的发布!增加了行业应用专栏
Odoo商城模块 Oejia_weshop v1.2 发布,多商户、分销增强,增加商家端!
处理 Error Failed to download metadata for repo ‘appstream‘ Cannot prepare internal mirrorlist
Odoo 16 关键变化 change the term "acquirer" to "provider"
企业微信错误码 81013 的排查与处理
微信模块 Oejia_wx v0.6.7 发布,支持 Odoo16 及新的Websocket消息模式
Friend Links
Oejia技术梦博客分享
YouMd,爱上MarkDown
Mole轻量级wsgi架子