golang定时任务cron项目实操指南
作者:DaSheng1104 发布时间:2023-08-26 00:21:40
标签:golang,定时任务,cron
一、简介:
1、cron包
cron包:"github.com/robfig/cron/v3"
文档:cron package - github.com/robfig/cron - Go Packages
2、表达式,go cron使用的和 Linux crontab 一样的表达式
# 文件格式說明
# ┌──分鐘(0 - 59)
# │ ┌──小時(0 - 23)
# │ │ ┌──日(1 - 31)
# │ │ │ ┌─月(1 - 12)
# │ │ │ │ ┌─星期(0 - 6,表示从周日到周六)
# │ │ │ │ │
# * * * * * 被執行的命令
3、新老版本区别
老版本的最大区别在于如果需要秒级定义,需要额外传入参数,并且可以自由配置参数
c := cron.New(cron.WithSeconds()) // 秒级操作cron.WithSeconds()
代码示例
package main
import (
"fmt"
"github.com/robfig/cron/v3"
"log"
"os"
)
func RunCron() {
c := cron.New(cron.WithSeconds(), cron.WithChain(cron.SkipIfStillRunning(cron.DefaultLogger)), cron.WithLogger(
cron.VerbosePrintfLogger(log.New(os.Stdout, "cron: ", log.LstdFlags))))
i := 1
EntryID, err := c.AddFunc("*/5 * * * * *", func() {
fmt.Println(time.Now(), "每5s一次----------------", i)
time.Sleep(time.Second *6)
i++
})
fmt.Println(time.Now(), EntryID, err)
c.Start()
select()
}
func main() {
RunCron()
}
多任务 AddJob
package main
import (
"fmt"
"github.com/robfig/cron/v3"
)
type Job1 struct {
}
func (t Job1) Run() {
fmt.Println(time.Now(), "I'm Job1")
}
type Job2 struct {
}
func (t Job2) Run() {
fmt.Println(time.Now(), "I'm Job2")
}
func RunCron() {
c := cron.New(cron.WithSeconds())
EntryID, err := c.AddJob("*/5 * * * * *", Job1{})
fmt.Println(time.Now(), EntryID, err)
EntryID, err = c.AddJob("*/10 * * * * *", Job2{})
fmt.Println(time.Now(), EntryID, err)
c.Start()
select()
}
func main() {
RunCron()
}
二、项目实操
数据统计系统 statsys 每天凌晨定时统计前一天运营数据
1、启动daemon 守护进程
package main
import (
"github.com/robfig/cron/v3"
logger "github.com/sirupsen/logrus"
"statsys/scheduler/crob_job" // 这里引入你的任务
)
func printLog(crobJob string, err error) {
if err != nil {
logger.Errorf("Start %s Error, err: %v", crobJob, err)
} else {
logger.Infof("Start %s Successful!", crobJob)
}
}
func RunCron() {
c := cron.New()
// 收入数据统计 定时任务(每天凌晨00:01:00)执行
_, err := c.AddJob("1 0 * * *", &crob_job.DeliveryIncomeStatJob)
printLog("IncomeStatJob", err)
// 支出数据统计 定时任务(每天凌晨00:03:00)执行
_, err = c.AddJob("3 0 * * *", &crob_job.PaymentStatJob)
printLog("PaymentStatJob", err)
// 启动一个新的 goroutine 做循环检测
c.Start()
select {}
}
func main() {
RunCron()
}
2、统计任务
// 支出数据统计定时任务
package crob_job
type paymentStatJob struct {
amountStatDataBase *amount_stat.AmountDataBase
}
// 单利
var (
PaymentStatJob = paymentStatJob{}
)
func (this *paymentStatJob) Run() {
logger.Warningln(">>>>>>>>>>>>> Start paymentStat")
startTime := "2022-01-02"
endTime := "2022-01-01"
// 查询统计数据
dataList, code := brawn.StationAccountSrv.GetPaymentDate(startTime, endTime)
if code != ecode.SUCC {
logger.Errorf("支出数据统计定时任务 errCode: %v", code)
return
}
if len(dataList) <= 0 {
logger.Warningln(" >>>>>>>> 暂无 支出数据 <<<<<<<<")
return
}
// 保存支付统计数据
this.amountStatDao.SavePaymentStatData(dataList...)
logger.Warningln("<<<<<<<<<<<<< End paymentStat")
}
... 具体你的项目多个任务
执行结果
来源:https://blog.csdn.net/LoganPython/article/details/125777340
![](https://www.aspxhome.com/images/zang.png)
![](https://www.aspxhome.com/images/jiucuo.png)
猜你喜欢
- Python算术运算符以下假设变量a为10,变量b为20:运算符描述实例+加 - 两个对象相加a + b 输出结果 30-减 - 得到负数或
- 最好不要在 base 环境中安装或者配置一些包之类的,它是 Python 的基础环境,为了更好的管理 Python 环境
- 我们或多或少都使用过各式各样的富文本编辑器,其中有一个很方便功能,复制一张图片然后粘贴进文本框,这张图片就被上传了,那么这个方便的功能是如何
- 默认级别:warningimport logginglogging.debug('debug message')loggin
- 1.相关基础python3中有两种字符串类型:str和bytespython编码问题可以参考文章str以unicode编码格式保存在内存所以
- 在许多网页中,当鼠标移到一张图片上时,又弹出另一张图片,做这种广告条,要用到Macromedia DreamWeaver中的Lay
- 一、从 4.0 到 4.1 的主要变化 如果在4.1.0到4.1.3版本的MySQL中创建了包含 TIMESTAMP 字段的 InnoDB表
- 由于js的代码逻辑越来越重,一个js文件可能会有上千行,十分不利于开发与维护。最近正在把逻辑很重的js拆分成模块,在一顿纠结是使用requi
- #mysql -uroot -p输入密码mysql> show full processlist;
- Python安装Graphviz画图器首先,要明确他是一个独立的软件,如果大家用pip的方法装了graphviz可以先卸载pip unins
- Python DataFrame 如何设置列表字段/元素类型?比如笔者想将列表的两个字段由float64设置为int64,那么就要用到Dat
- 方法1:/** 功能:数据备份/恢复文件简易方法* 以日期为单位,一天一个备份文件,以当天最后备份为准* 用提交表单的形式进行操作,* 其中
- 开发环境开发环境为:Win 10(64位)Python 3.7.0Django 2.1安装Pythonpython的安装为比较简单,首先找到
- 本文为大家分享了js实现简单选项卡功能的具体代码,供大家参考,具体内容如下首先我们来写HTML代码,构建出整体结构代码如下:<!--导
- 爆库语句,修改红色部分的数字挨个猜出库 /**/and/**/(select/**/top/**/1/**/isnull(cast([nam
- Python中print()函数的方法是打印指定的内容。在交互环境中输入“help(print)”指
- 相信没有人不知道 Firebug 是什么东西,但有时候我们糟糕的代码不想让同行轻松的使用 F12 就能一览无遗。那么怎么办呢?这里有个猥琐的
- 代码: <input type="text" value="fisker" onclick=&
- 本文实例讲述了微信小程序实现获取自己所处位置的经纬度坐标功能。分享给大家供大家参考,具体如下:1、效果展示2、关键代码index.wxml布
- 标量(scalar)数据类型标量(scalar)数据类型没有内部组件,他们大致可分为以下四类:. number. character. da