pickle.dumps报错,求大佬带带弟弟,弟弟不行了

chendaxians

python3.8,
nonebot最新,
apscheduler模块最新

最近使用nonebot写了一个小程序,可以定闹钟这样子,用了apscheduler模块,想用sqlite把闹钟储存在本地

1. 'apscheduler.jobstores.default': {
   
2.         'type': 'sqlalchemy',
   
3.         'url': database_call,    # sql:///D:\\date.db
   
4.         'tablename': 'apscheduler_jobs'
   
5.     }

复制代码

然后这里是apscheduler模块的添加任务的函数,这里最后一行代码就报错了,如何解决呢

1. _pickle.PicklingError: Can't pickle <function main_clock at 0x041E3610>: it's not the same object as App.plugins.Call_me_now.main_clock

复制代码

1.    def add_job(self, job):
   
2.         insert = self.jobs_t.insert().values(**{
   
3.             'id': job.id,
   
4.             'next_run_time': datetime_to_utc_timestamp(job.next_run_time),
   
5.             'job_state': pickle.dumps(job.__getstate__(), self.pickle_protocol)
   
6.         })

复制代码

dlnb526

这是由于main_clock函数无法直接通过pickle.dump写入到pkl文件中。你哪里调用了你没发代码，应该时pickle序列化的对象你应该转换一下类型~

chendaxians

dlnb526 发表于 2020-4-5 21:11
这是由于main_clock函数无法直接通过pickle.dump写入到pkl文件中。你哪里调用了你没发代码，应该时pickle序 ...

1. 
   
2. import datetime
   
3. from apscheduler.triggers.date import DateTrigger
   
4. from apscheduler.triggers.cron import CronTrigger
   
5. from nonebot import on_command, scheduler, CommandSession, message, on_startup
   
6. from apscheduler.jobstores.sqlalchemy import SQLAlchemyJobStore
   
7. from config import database_call
   
8. # sql:///D:\\date.db
   
9. @on_startup
   
10. async def scheduler_clock():
    
11.     call_me = SQLAlchemyJobStore(url=database_call)
    
12.     scheduler.add_jobstore(call_me, "call")
    
13. 
    
14. @on_command('clock', aliases=('闹钟', '定个闹钟'), only_to_me=False)
    
15. async def main_clock(session: CommandSession):
    
16.     time = session.get('time', prompt=r'请问您要定一个几点的闹钟?')
    
17. 
    
18.     # 制作一个“5分钟后”触发器
    
19.     delta = datetime.timedelta(minutes=float(time))
    
20.     trigger = DateTrigger(
    
21.         run_date=datetime.datetime.now() + delta
    
22.     )
    
23. 
    
24.     # 添加任务
    
25.     scheduler.add_job(
    
26.         func=session.send,  # 要添加任务的函数，不要带参数
    
27.         trigger=trigger,  # 触发器
    
28.         args=('您定的闹钟时间到了',),  # 函数的参数列表，注意：只有一个值时，不能省略末尾的逗号
    
29.         misfire_grace_time=60,
    
30.         jobstore='call',
    
31. 
    
32.     )
    
33. 
    
34.     await session.send('已经为您订好了一个' + time + '分钟的闹钟')
    

复制代码

大佬看看,这是源码,我搞不太定了,淦