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
2018-07-07 :
Odoo 菜单美化的扩展模块
2021-01-23 :
Odoo 如何用命令行备份还原数据
2014-12-6 :
PyQt界面控件常用积累
2017-10-24 :
Odoo 前端对象 options 介绍
2018-11-23 :
Odoo 菜单定制模块 Oejia_menu v0.2.0 发布!
2016-04-20 :
怎么安装 yum 环境
2014-12-15 :
Cordova开发环境搭建与基本使用
2014-12-22 :
MoCrud(快速建立关系型数据管理系统)
2018-04-24 :
DjangoX v0.5 发布,支持Python3的强大灵活后台系统
2022-07-11 :
Odoo 客户管理之微信定位模块
官方订阅号
关注订阅实时了解我们更多分享
分类
(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
客服系统
HTML5
审批OA
OE商城
Markdown
DjangoX
PyQT
YouPBX
解析
Excel
markdown
oeshop
服系统
示例
Python
md
最近发布
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架子