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
2017-03-22 :
Vim
2022-11-03 :
使用说明文档
2021-09-28 :
OE 商城销售资料汇集
2018-07-06 :
微信模块 Oejia_wx v0.5.3 发布,增加聊天图片和语音的支持
2019-03-26 :
微信模块 Oejia_wx v0.5.8 发布,多会话客服消息支持及素材图文方面增强
2016-03-19 :
从 odoo 源码看 odoo 8.0 到 9.0 的变化
2014-12-1 :
开篇感言
2024-01-16 :
Drone CI/CD相关
2018-07-07 :
Odoo 菜单美化的扩展模块
2017-11-02 :
Odoo 交互式命令行 shell 的使用
官方订阅号
关注订阅实时了解我们更多分享
分类
(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架子