搜索到
617
篇与
的结果
-
-
-
-
Linux进程守护，supervisor安装及使用 用Linux挂一些Python脚本啥的就离不开进程守护这个东西了，然后了解到supervisor似乎还不错，在网上经过一番折腾及搜索，于是在此总结一下。Supervisor安装及配置这里我演示的系统是：CentOS Linux release 7.7.1908 (Core)一、使用yum安装supervisoryum install supervisor遇到下图，输入y即可。安装完成：二、设置开机启动systemctl enable supervisord.service四、编辑配置文件进入到etc目录，就找到看到supervisord.conf这个文件了编辑该文件（咳咳，宝塔面板真香）files改成放配置文件的文件夹，默认就好然后我们在进入supervisord.d文件夹。五、添加，配置ini文件在里面新建文件，后缀为之前配置文件中的ini即可。这个就是用来存放监控配置的相关信息了[program:DeployLinux] #DeployLinux 为程序的名称 command=dotnet DeployLinux.dll #需要执行的命令 directory=/home/publish #命令执行的目录 environment=ASPNETCORE__ENVIRONMENT=Production #环境变量 注释符不用# 环境变量可以省略 user=root #用户 stopsignal=INT autostart=true #是否自启动 autorestart=true #是否自动重启 startsecs=3 #自动重启时间间隔（s） stderr_logfile=/var/log/ossoffical.err.log #错误日志文件 stdout_logfile=/var/log/ossoffical.out.log #输出日志文件配置实例 [program:future_price_depth_new.py] command=python /bot/mkr/future_price_depth_new.py 注意intergal_util.py用python3启动 [command=python3 /bot/mkr/future_price_depth_new.py] directory=/bot/mkr/ user=root stopsignal=INT autostart=true autorestart=true startsecs=3 stderr_logfile=/bot/log/future_price_depth_new.err.log stdout_logfile=/bot/log/future_price_depth_new.out.log六、启动supervisord -c /etc/supervisor/supervisord.conf-c 表示启动自己之前创建的配置文件的supervisor 后面跟着的就是路径基本使用指令supervisord -c supervisor.conf 通过配置文件启动supervisorsupervisorctl -c supervisor.conf status 查看状态supervisorctl -c supervisor.conf reload 重新载入配置文件supervisorctl -c supervisor.conf start [all]|[x] 启动所有/指定的程序进程supervisorctl -c supervisor.conf stop [all]|[x] 关闭所有/指定的程序进程输入supervisorctl进入命令行工具因为我这台服务器暂不需要挂东西，所以我切换到我挂了东西的服务器（这是废话，忽略即可）这里我有两个conf（因为我将配置文件中的ini改成了conf，所以后缀是conf）文件，所以会显示有两个任务可以通过下述指令操作任务：supervisorctl status：查看所有进程的状态supervisorctl stop es：停止essupervisorctl start es：启动essupervisorctl restart es: 重启essupervisorctl update ：配置文件修改后可以使用该命令加载新的配置supervisorctl reload: 重新启动配置中的所有程序
-
-
Apscheduler时间调度程序——python定时任务 1.简介APScheduler的全称是Advanced Python Scheduler。它是一个轻量级的 Python 定时任务调度框架。APScheduler 支持三种调度任务：固定时间间隔，固定时间点（日期），Linux 下的 Crontab 命令。同时，它还支持异步执行、后台执行调度任务。2. 安装 pip install APScheduler3. 基础组件APScheduler 有四种组件，分别是：调度器(scheduler)，作业存储(job store)，触发器(trigger)，执行器(executor)。schedulers（调度器）它是任务调度器，属于控制器角色。它配置作业存储器和执行器可以在调度器中完成，例如添加、修改和移除作业。triggers（触发器）描述调度任务被触发的条件。不过触发器完全是无状态的。job stores（作业存储器）任务持久化仓库，默认保存任务在内存中，也可将任务保存都各种数据库中，任务中的数据序列化后保存到持久化数据库，从数据库加载后又反序列化。executors（执行器）负责处理作业的运行，它们通常通过在作业中提交指定的可调用对象到一个线程或者进城池来进行。当作业完成时，执行器将会通知调度器。""" date 触发器使用示例如下： date 触发器指在某一指定时间下执行脚本的方法 """ from datetime import datetime from datetime import date from apscheduler.schedulers.background import BackgroundScheduler def job_func(text): print(text) scheduler = BackgroundScheduler() # 在 2017-12-13 时刻运行一次 job_func 方法 scheduler .add_job(job_func, 'date', run_date=date(2017, 12, 13), args=['text']) # 在 2017-12-13 14:00:00 时刻运行一次 job_func 方法 scheduler .add_job(job_func, 'date', run_date=datetime(2017, 12, 13, 14, 0, 0), args=['text']) # 在 2017-12-13 14:00:01 时刻运行一次 job_func 方法 scheduler .add_job(job_func, 'date', run_date='2017-12-13 14:00:01', args=['text']) scheduler.start()""" interval 触发器 循环执行脚本任务的触发器 weeks (int) – 间隔几周 days (int) – 间隔几天 hours (int) – 间隔几小时 minutes (int) – 间隔几分钟 seconds (int) – 间隔多少秒 start_date (datetime|str) – 开始日期 end_date (datetime|str) – 结束日期 timezone (datetime.tzinfo|str) – 时区 """ import datetime from apscheduler.schedulers.background import BackgroundScheduler def job_func(text): print(datetime.datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S.%f")[:-3]) scheduler = BackgroundScheduler() # 每隔两分钟执行一次 job_func 方法 scheduler .add_job(job_func, 'interval', minutes=2) # 在 2017-12-13 14:00:01 ~ 2017-12-13 14:00:10 之间, 每隔两分钟执行一次 job_func 方法 scheduler .add_job(job_func, 'interval', minutes=2, start_date='2017-12-13 14:00:01' , end_date='2017-12-13 14:00:10') scheduler.start()""" cron 触发器使用示例如下： 指定指定时间循环执行脚本的触发器 year (int|str) – 年，4位数字 month (int|str) – 月 (范围1-12) day (int|str) – 日 (范围1-31) week (int|str) – 周 (范围1-53) day_of_week (int|str) – 周内第几天或者星期几 (范围0-6 或者 mon,tue,wed,thu,fri,sat,sun) hour (int|str) – 时 (范围0-23) minute (int|str) – 分 (范围0-59) second (int|str) – 秒 (范围0-59) start_date (datetime|str) – 最早开始日期(包含) end_date (datetime|str) – 最晚结束时间(包含) timezone (datetime.tzinfo|str) – 指定时区 """ import datetime from apscheduler.schedulers.background import BackgroundScheduler def job_func(text): print("当前时间：", datetime.datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S.%f")[:-3]) scheduler = BackgroundScheduler() # 在每年 1-3、7-9 月份中的每个星期一、二中的 00:00, 01:00, 02:00 和 03:00 执行 job_func 任务 scheduler .add_job(job_func, 'cron', month='1-3,7-9',day='0, tue', hour='0-3') scheduler.start()参考链接：https://www.cnblogs.com/luxiaojun/p/6567132.html参考链接：https://www.cnblogs.com/ohyb/p/9084011.html参考链接：https://www.cnblogs.com/cool-fire/p/7449758.html参考链接：http://www.cnblogs.com/luxiaojun/p/6567132.html官方文档：https://apscheduler.readthedocs.io/en/latest/userguide.html#basic-concepts
-
OPQ机器人框架插件开发之Python模板 今天了解到还有个OPQ的框架似乎还不错，于是研究了一下，比酷Q还方便（因为我之前用的air版，图片都发不了）并且支持多平台，但是最新的版本居然阉割了Windows下的许多功能不过问题不大，满足我之前的需求了。于是参考了一下原本iot的python模板然后进行了修改，更加符合自己的用法习惯吧。然后就是代码：botConfig->configInfo.py（用于存放接口地址，以及机器人QQ）robotQQ = "{机器人QQ}" webapi = "{接口地址，后面无需加/}"botConfig ->botClass.py （用于存放一些对消息的解析类）import json import requests from .configInfo import * """ By : Lan Website : """ # 群组消息接受类 class GroupMess: def __init__(self, message): self.FromQQG = message['FromGroupId'] # 来源QQ群 self.QQGName = message['FromGroupName'] # 来源QQ群昵称 self.FromQQ = message['FromUserId'] # 来源QQ self.FromQQName = message['FromNickName'] # 来源QQ名称 self.Content = message['Content'] # 消息内容 self.MsgTime = message['MsgTime'] # 消息时间 # 私发消息接受类 class PrivateMess: def __init__(self, message): self.FromQQ = message['ToUin'] # 来源QQ号 self.ToQQ = message['FromUin'] # 目标QQ号 self.Content = message['Content'] # 消息内容 self.MsgType = message['MsgType'] # 消息类型 # 发送消息类 class SendMessage: def __init__(self, toUser=0, sendToType=0, sendMsgType='', groupId=0, content='', atUser=0, voiceUrl='', picUrl='', picBase64Buf='', voiceBase64Buf=''): self.data = { "toUser": toUser, # 欲发给的对象 群或QQ好友或私聊对象 "sendToType": sendToType, # 发送消息对象的类型 1好友 2群3私聊 "sendMsgType": sendMsgType, # 欲发送消息的类型 TextMsg、PicMsg、VoiceMsg "content": content, # 发送的文本内容 "groupid": groupId, # 发送私聊消息是 在此传入群ID 其他情况为0 "atUser": atUser, # At用户 传入用户的QQ号 其他情况为0 "picUrl": picUrl, # 发送图片的网络地址 "picBase64Buf": picBase64Buf, # 发本地送图片的buf 转 bas64 编码 "voiceUrl": voiceUrl, # 发送语音的网络地址 "voiceBase64Buf": voiceBase64Buf, # 发本地送语音的buf 转 bas64 编码 "fileMd5": "" } ''' 发送图片消息需要有：toUser sendToType sendMsgType picUrl ''' def send(self): print(self.data) requests.post(url=f'{webapi}/v1/LuaApiCaller?qq={robotQQ}&funcname=SendMsg&timeout=10', data=json.dumps(self.data)) return 200main.py （用于存放主文件）# coding=utf-8 import logging import time import socketio from botConfig.botClass import * from botConfig.configInfo import * sio = socketio.Client() """ By : Lan Website : https://gitlab.com/Vastsa/lanpicbed/-/raw/master/ """ def beat(): while True: sio.emit('GetWebConn', robotQQ) time.sleep(60) @sio.event def connect(): print('connected to server') sio.emit('GetWebConn', robotQQ) # 取得当前已经登录的QQ链接 beat() # 心跳包，保持对服务器的连接 @sio.on('OnGroupMsgs') def OnGroupMsgs(message): """ 监听群组消息""" data = GroupMess(message['CurrentPacket']['Data']) print(data) return @sio.on('OnFriendMsgs') def OnFriendMsgs(message): """ 监听好友消息 """ data = PrivateMess(message['CurrentPacket']['Data']) print(data) return @sio.on('OnEvents') def OnEvents(message): """ 监听相关事件""" print(message) def main(): try: sio.connect(webapi, transports=['websocket']) sio.wait() except BaseException as e: logging.info(e) print(e) if __name__ == '__main__': main()GitHub地址：https://github.com/vastsa/OPQBot-Pyhon
