这个出错可谓是出乎意外,因为在此之前从未出错过。
在修改了DJ中celery.py中的CELERYBEAT_SCHEDULE内容之后,运行beat时,居然报错了。
从报错的内容看,应该时数据库中的写入数据的字长超过了200个。但是从已经完成的内容看,没有一个字长内容会超过200个字符。
修改了相关表的字长从200到400,仍然报错。看来哪里有问题了。
由于出错提示没有告知具体内容,但是提示了在那行出错,于是就直接跑到了在当前虚拟python下的django_celery_beat文件夹中(lib…),然后打开utils.py文件,找到运行sql语句的地方,在运行sql语句之前,添加了一句print(提示需要admin的权限,根据提示确认即可)
def _execute(self, sql, params, *ignored_wrapper_args):
......
print(sql, params)
return self.cursor.execute(sql, params)
结果发现,该sql所带的参数表params中,在某个字段下,出现了异常的数,一查看,居然是celery.py文件中CELERYBEAT_SCHEDULE(定义task任务的执行计划的json数据)的内容。我尼玛。
CELERYBEAT_SCHEDULE = {
"""
"""
}
确认后,是因为由于之前将几个不再使用的task使用"""对的方式注释掉了,但是对于解读该json格式的celery_beat来说,却把你注释掉的仍然作为有效的字符串来处理,而且全部作为后续未注释紧邻的task的name的一部分了。难怪。一看数据长度,超过了500个字节!
发现原因,就好处理了。
–直接删除不用的任务。停止celery,重新启动服务器,然后在后台重新设置任务。
再次运行celery的task和beat,就恢复了正常。
在数据库中直接改回字段长度。
收工。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)