【Python脚本】定时任务脚本实现、自动关机等功能脚本实现（保姆篇）

news2024/9/28 15:34:00

在这里插入图片描述

文章目录

  • 功能描述
  • 源码分析
      • 依赖
      • 参数配置
      • 数据校验
      • 多线程并发执行
      • 定时任务注册
      • 自动关机
      • 主程序
  • 源码整合
  • 本篇小结

更多相关内容可查看

功能描述

需要python环境，详情可看主页python相关文章【Python】从0开始写脚本、Selenium详细教程、附源码案例（保姆篇）

源码分析

依赖

from selenium import webdriver
from selenium.webdriver.common.by import By
import time
import threading
import schedule
import datetime
import subprocess
import sys
import re

参数配置

#手机号
phon_num = "155xxxxx"
#定时任务间隔时间（分钟）
interval = 2
#定时任务开始时间
start_time = "12:10"
#定时任务结束时间
end_time = "12:20"
#控制台打印间隔时间（秒）
printtime = 30
#执行完是否自动关机（True）
shutdown_flag = False

数据校验

def is_eleven_digit_number(element):
    return element.isdigit() and len(element) == 11
def is_time_format(element):
    pattern = r'^\d{2}:\d{2}$'
    return bool(re.match(pattern, element))
    
def checkdata():
    if not is_eleven_digit_number(phon_num):
        print(f'{phon_num} :不是一个正确的手机号码,请修改！')
        sys.exit(1)
    if not is_time_format(start_time):
        print(f'{start_time} :不符合时间格式 "HH:MM",请修改！')
        sys.exit(1)
    if not is_time_format(end_time):
        print(f'{end_time} :不符合时间格式 "HH:MM",请修改！')
        sys.exit(1)

这段代码是一个简单的数据验证函数 checkdata()，用于检查输入数据的有效性。它依赖两个辅助函数 is_eleven_digit_number() 和 is_time_format() 来验证不同类型的数据：

  1. is_eleven_digit_number(element): 这个函数用于检查给定的 element 是否是一个11位的数字字符串。它首先使用 isdigit() 方法检查字符串是否全由数字组成，然后使用 len(element) == 11 来确保字符串长度为11位。

  2. is_time_format(element): 这个函数用于验证时间格式是否符合 “HH:MM” 的形式，即两位小时和两位分钟，中间用冒号分隔。它使用正则表达式 ^\d{2}:\d{2}$ 来匹配这种格式，确保输入的字符串满足要求。

在 checkdata() 函数中：

  • 首先检查变量 phon_num 是否为一个11位的数字串，如果不是，则打印提示信息并终止程序执行。
  • 然后分别检查 start_time 和 end_time 是否符合 “HH:MM” 的时间格式要求，如果不符合则同样打印提示信息并终止程序执行。

这段代码的目的是确保输入数据的格式正确，以便后续的处理能够顺利进行。

多线程并发执行

def execute_tasks():
    threads = [
        threading.Thread(target=send_paipai, args=(phon_num,)),
        threading.Thread(target=func3, args=(phon_num,)),
        threading.Thread(target=send_chuanhang, args=(phon_num,)),
        threading.Thread(target=send_wushang, args=(phon_num,)),
        threading.Thread(target=send_caiyun, args=(phon_num,)),
        threading.Thread(target=send_phpzw, args=(phon_num,)),
        threading.Thread(target=func9, args=(phon_num,)),
        threading.Thread(target=func1, args=(phon_num,)),
        threading.Thread(target=func21, args=(phon_num,)),
        threading.Thread(target=send_spump, args=(phon_num,)),
        threading.Thread(target=func24, args=(phon_num,)),
        threading.Thread(target=func19, args=(phon_num,)),
        threading.Thread(target=func10, args=(phon_num,))
    ]

    for t in threads:
            t.start()

    for t in threads:
            t.join()

    print("本轮已发送完成")

这段代码是一个并发执行多个任务的函数 execute_tasks()。它使用了多线程的方式，同时启动了多个线程来执行不同的任务，然后等待所有线程执行完毕后输出完成信息。

具体描述如下：

  1. 创建线程列表：

    • 代码首先定义了一个列表 threads，其中包含了多个 threading.Thread 对象。
    • 每个 threading.Thread 对象通过 target= 指定要执行的函数，通过 args= 传入该函数需要的参数。这些函数包括 send_paipai(), func3(), send_chuanhang(), 等等，每个函数都以 phon_num 作为参数。

  2. 启动线程：

    • 使用一个 for 循环遍历 threads 列表，对每个线程对象调用 start() 方法启动线程。这样可以并发执行每个任务，而不是按顺序逐个执行。

  3. 等待线程结束：

    • 接着使用另一个 for 循环遍历 threads 列表，对每个线程对象调用 join() 方法。join() 方法会阻塞主线程，直到被调用线程执行完毕才会继续执行主线程。
    • 这段代码确保所有任务都执行完成后才会继续往下执行，以保证后续操作不会受到未完成任务的影响。

  4. 输出完成信息：

    • 最后打印一条信息 “本轮已发送完成”，表示所有任务都已经成功执行完毕。

总体来说，这段代码利用多线程的方式提高了任务执行的效率，特别适合需要并发执行多个独立任务的场景，如发送多个通知或处理多个独立的数据处理任务。

定时任务注册

def register_hourly_tasks():
    while True:
        current_time = datetime.datetime.now().strftime("%H:%M")
        if start_time <= current_time <= end_time:
            # 如果当前时间在定时任务时间范围内，注册任务
            while current_time <= end_time:
                schedule.every().day.at(current_time).do(execute_tasks)
                print(f"已注册定时任务执行时间：{current_time}")
                current_time = (datetime.datetime.strptime(current_time, "%H:%M") + datetime.timedelta(
                    minutes=interval)).strftime("%H:%M")
            else:
                break
        else:
            # 如果当前时间不在定时任务时间范围内，计算距离下一个任务开始的时间
            if current_time < start_time:
                next_time = start_time
            else:
                next_time = (datetime.datetime.strptime(current_time, "%H:%M") + datetime.timedelta(
                    minutes=interval)).strftime("%H:%M")

            next_start = datetime.datetime.strptime(next_time, "%H:%M")
            current_datetime = datetime.datetime.now()
            delta = next_start - current_datetime

            hours = delta.seconds // 3600
            minutes = (delta.seconds // 60) % 60
            seconds = delta.seconds % 60

            print(f"当前时间为 {current_datetime.strftime('%H:%M')}, 距离定时任务开始还剩 {hours} 小时 {minutes} 分钟 {seconds} 秒")
            time.sleep(printtime)

这段代码定义了一个函数 register_hourly_tasks()，用于注册和执行定时任务。

  1. 主循环逻辑：

    • 函数通过一个 while True 循环来持续执行任务注册和计时功能。

  2. 获取当前时间：

    • 使用 datetime.datetime.now().strftime("%H:%M") 获取当前时间的小时和分钟，格式化为字符串 “%H:%M”。

  3. 判断当前时间是否在任务时间范围内：

    • 如果 current_time 在指定的 start_time 和 end_time 范围内，则执行以下操作：
      • 进入内部的 while 循环，该循环会注册多个定时任务，直到 current_time 大于 end_time。
      • 使用 schedule.every().day.at(current_time).do(execute_tasks) 注册定时任务，指定任务执行的时间为 current_time。
      • 打印信息表明已经注册了定时任务的执行时间。
      • 更新 current_time，使其增加 interval 分钟后继续注册下一个任务。

  4. 处理不在任务时间范围内的情况：

    • 如果 current_time 不在指定的时间范围内，则执行以下操作：
      • 确定下一个任务开始的时间 next_time，如果 current_time 小于 start_time，则下一个任务从 start_time 开始；否则，从当前时间加上 interval 分钟后开始。
      • 计算距离下一个任务开始的时间差 delta。
      • 将时间差 delta 转换成小时、分钟和秒数，并打印出距离下一个任务开始的剩余时间。
      • 使用 time.sleep(printtime) 让程序休眠，直到下一个任务开始的时间，以节省系统资源和避免不必要的轮询。

总体来说，这段代码通过使用 schedule 模块实现了根据时间注册和执行定时任务，并提供了实时的时间信息反馈和等待功能，使得任务的执行更加自动化和精确。

自动关机

def shutdown_computer():
    subprocess.run(["shutdown", "/s", "/t", "1"])

主程序

def start():
    #数据校验
    checkdata()
    #定时任务注册
    register_hourly_tasks()
    #定时任务执行
    while  datetime.datetime.now().strftime("%H:%M") <= end_time:
        schedule.run_pending()
        time.sleep(30)
    #清空定时任务
    schedule.clear()
    #关机
    if shutdown_flag:
        shutdown_computer()

if __name__ == "__main__":
    start()

源码整合

#手机号
phon_num = "155xxxxx"
#定时任务间隔时间（分钟）
interval = 2
#定时任务开始时间
start_time = "12:10"
#定时任务结束时间
end_time = "12:20"
#控制台打印间隔时间（秒）
printtime = 30
#执行完是否自动关机（True）
shutdown_flag = False

def is_eleven_digit_number(element):
    return element.isdigit() and len(element) == 11
def is_time_format(element):
    pattern = r'^\d{2}:\d{2}$'
    return bool(re.match(pattern, element))
def execute_tasks():
    threads = [
        threading.Thread(target=send_paipai, args=(phon_num,)),
        threading.Thread(target=func3, args=(phon_num,)),
        threading.Thread(target=send_chuanhang, args=(phon_num,)),
        threading.Thread(target=send_wushang, args=(phon_num,)),
        threading.Thread(target=send_caiyun, args=(phon_num,)),
        threading.Thread(target=send_phpzw, args=(phon_num,)),
        threading.Thread(target=func9, args=(phon_num,)),
        threading.Thread(target=func1, args=(phon_num,)),
        threading.Thread(target=func21, args=(phon_num,)),
        threading.Thread(target=send_spump, args=(phon_num,)),
        threading.Thread(target=func24, args=(phon_num,)),
        threading.Thread(target=func19, args=(phon_num,)),
        threading.Thread(target=func10, args=(phon_num,))
    ]

    for t in threads:
            t.start()

    for t in threads:
            t.join()

    print("本轮已发送完成")
def register_hourly_tasks():
    while True:
        current_time = datetime.datetime.now().strftime("%H:%M")
        if start_time <= current_time <= end_time:
            # 如果当前时间在定时任务时间范围内，注册任务
            while current_time <= end_time:
                schedule.every().day.at(current_time).do(execute_tasks)
                print(f"已注册定时任务执行时间：{current_time}")
                current_time = (datetime.datetime.strptime(current_time, "%H:%M") + datetime.timedelta(
                    minutes=interval)).strftime("%H:%M")
            else:
                break
        else:
            # 如果当前时间不在定时任务时间范围内，计算距离下一个任务开始的时间
            if current_time < start_time:
                next_time = start_time
            else:
                next_time = (datetime.datetime.strptime(current_time, "%H:%M") + datetime.timedelta(
                    minutes=interval)).strftime("%H:%M")

            next_start = datetime.datetime.strptime(next_time, "%H:%M")
            current_datetime = datetime.datetime.now()
            delta = next_start - current_datetime

            hours = delta.seconds // 3600
            minutes = (delta.seconds // 60) % 60
            seconds = delta.seconds % 60

            print(f"当前时间为 {current_datetime.strftime('%H:%M')}, 距离定时任务开始还剩 {hours} 小时 {minutes} 分钟 {seconds} 秒")
            time.sleep(printtime)
def shutdown_computer():
    subprocess.run(["shutdown", "/s", "/t", "1"])
def checkdata():
    if not is_eleven_digit_number(phon_num):
        print(f'{phon_num} :不是一个正确的手机号码,请修改！')
        sys.exit(1)
    if not is_time_format(start_time):
        print(f'{start_time} :不符合时间格式 "HH:MM",请修改！')
        sys.exit(1)
    if not is_time_format(end_time):
        print(f'{end_time} :不符合时间格式 "HH:MM",请修改！')
        sys.exit(1)
def start():
    #数据校验
    checkdata()
    #定时任务注册
    register_hourly_tasks()
    #定时任务执行
    while  datetime.datetime.now().strftime("%H:%M") <= end_time:
        schedule.run_pending()
        time.sleep(30)
    #清空定时任务
    schedule.clear()
    #关机
    if shutdown_flag:
        shutdown_computer()

if __name__ == "__main__":
    start()

本篇小结

这里没给出的部分脚本为如下方法：(可私信或留言获取)

在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1980701.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

3dsMax模型展开UV之后无法删除，3dsmax删除模型上已经展开的UV

3dsMax模型展开UV之后无法删除，3dsmax删除模型上已经展开的UV

3dsmax展开UV之后如何删除UV 方法二 如果不能重置UV通道&#xff0c;在实用工具》更多工具》UVW移除&#xff0c;选中模型&#xff0c;点击UVW移除&#xff0c;移除模型的UVW。
阅读更多...
机器人抓取与操作的挑战与进展——挑战赛角度

机器人抓取与操作的挑战与进展——挑战赛角度

从竞赛中看机器人抓取与操作的挑战与进展 前言一、国际机器人竞赛有哪些&#xff1f;二、感知方面的挑战与进展二、抓取方面的挑战与进展三、操作方面的挑战与进展总结 前言 本文根据最近的机器人抓取和操作挑战赛 (Robotic Grasping andManipulation Competitions (RGMCs))&a…
阅读更多...
OCR图片矫正、表格检测及裁剪综合实践

OCR图片矫正、表格检测及裁剪综合实践

问题描述 实际工程中&#xff0c;我们经常需要对图片进行预处理&#xff0c;比如&#xff1a; 1、图片是倾斜的 2、图片背景需要处理掉 3、图片的公章需要剔除 4、图片过暗&#xff0c;过亮 5、图片表格检测 6、图片表格版面分析 。。。。。。等等各种情况。 结果展示…
阅读更多...
解决PuppeteerSharp生成PDF颜色问题的最佳实践

解决PuppeteerSharp生成PDF颜色问题的最佳实践

在现代网络开发中&#xff0c;使用爬虫技术生成PDF文件已成为一种常见需求。然而&#xff0c;开发者经常会遇到一些棘手的问题&#xff0c;其中之一便是使用PuppeteerSharp生成PDF时颜色丢失的问题。本篇文章将概述如何解决这一问题&#xff0c;并提供最佳实践和相关代码示例。…
阅读更多...
TI音频功放TAS6511（二）

TI音频功放TAS6511（二）

3.数字音频处理 芯片支持高级数字音频处理能力&#xff0c;包括&#xff1a; 高通滤波器/直流阻断 数字音量控制 PVDD的Foldback/AGL 热Foldback 双象限增益补偿 混合调制 实时负载诊断 低延迟路径 喇叭功率限制 1&#xff09;PVDD Foldback 本功能主要为了防止音频…
阅读更多...
学习笔记--算法（双指针）2

学习笔记--算法（双指针）2

复写零 链接&#xff1a;https://leetcode.cn/problems/duplicate-zeros/ 题目 给你一个长度固定的整数数组 arr &#xff0c;请你将该数组中出现的每个零都复写一遍&#xff0c;并将其余的元素向右平移。 注意&#xff1a;请不要在超过该数组长度的位置写入元素。请对输入的…
阅读更多...
分享一个基于微信小程序的旅游自助拼团系统（源码、调试、LW、开题、PPT）

分享一个基于微信小程序的旅游自助拼团系统（源码、调试、LW、开题、PPT）

&#x1f495;&#x1f495;作者&#xff1a;计算机源码社 &#x1f495;&#x1f495;个人简介&#xff1a;本人 八年开发经验&#xff0c;擅长Java、Python、PHP、.NET、Node.js、Android、微信小程序、爬虫、大数据、机器学习等&#xff0c;大家有这一块的问题可以一起交流&…
阅读更多...
想业余时间做个网赚项目，有啥捷径？

想业余时间做个网赚项目，有啥捷径？

前两年我陷入一段迷茫、浮躁、焦虑期。 主要原因是&#xff0c;心很大&#xff0c;力不足。 总想着找到一个高利润、高复购、少竞争的“蓝海”产品。 于是就面临一个尴尬的境地&#xff1a;普通业务看不上&#xff0c;蓝海业务找不着。 而且总想着做推广一步登天&#xff0…
阅读更多...
程序员日志之DNF手游女鬼剑前瞻

程序员日志之DNF手游女鬼剑前瞻

目录 传送门正文日志1、概要女鬼剑 传送门 SpringMVC的源码解析&#xff08;精品&#xff09; Spring6的源码解析&#xff08;精品&#xff09; SpringBoot3框架&#xff08;精品&#xff09; MyBatis框架&#xff08;精品&#xff09; MyBatis-Plus SpringDataJPA SpringClou…
阅读更多...
【教资 · 科目一】综合素质

【教资 · 科目一】综合素质

【科目一】综合素质 单选题&#xff1a;29道/2分&#xff0c;共58分材料分析题&#xff1a;3道/14分&#xff0c;共42分写作题&#xff1a;1道&#xff0c;50分 卷面满分150分 —— 报告满分120分 及格分数99分以上 —— 及格分数70分 ‍ 考试内容&#xff1a; 职业理念&a…
阅读更多...
Flink笔记整理（七）

Flink笔记整理（七）

Flink笔记整理&#xff08;七&#xff09; 文章目录 Flink笔记整理&#xff08;七&#xff09;九、容错机制9.1 检查点&#xff08;Checkpoint&#xff09;检查点的保存从检查点恢复状态检查点算法9.2 状态一致性9.3 端到端精确一次&#xff08;End-To-End Exactly-Once&#x…
阅读更多...
中科亿海微SoM模组——光纤陀螺控制板

中科亿海微SoM模组——光纤陀螺控制板

光纤陀螺控制板 光纤陀螺仪是一种高精度、高可靠性的惯性测量仪器&#xff0c;被广泛应用于导航、姿态控制等应用场景&#xff0c;具有非常重要的应用价值。 本文介绍的光纤陀螺控制板是基于中科亿海微自研的SiP芯片平台&#xff0c;以及光纤陀螺数字信号处理流程&#xff0c…
阅读更多...
安泰高压功率放大器的作用以及应用有哪些

安泰高压功率放大器的作用以及应用有哪些

高压功率放大器是一种用于增强信号强度的电子设备。它的作用是将输入信号的功率放大到足够的水平&#xff0c;以便在系统中进行传输或执行特定的任务。高压功率放大器在各种领域都有广泛的应用&#xff0c;从通信到科学研究再到医疗设备等多个领域都可以找到其身影。 高压功率放…
阅读更多...
echarts横向柱状图

echarts横向柱状图

一、效果图 二、代码 let option {grid: {top: 8%,bottom: -20,right: 20,left: 20,containLabel: true},xAxis: {show: false},yAxis: [{triggerEvent: true,show: true,inverse: true,data: getArrByKey(data, name),axisLine: {show: false},splitLine: {show: false},axi…
阅读更多...
React（五）：XLS、XLSX文件在线预览

React（五）：XLS、XLSX文件在线预览

效果 依赖 $ yarn add xlsx源码 .xlsx-wrap {position: relative;width: 100%;height: 100%;background-color: #fafafa;.ant-tabs {width: 100%;height: 100%;.ant-tabs-nav {height: 50px;padding: 0 10px;margin-bottom: 0;}.ant-tabs-content-holder {border-top: 1px so…
阅读更多...
JavaScript对象转数组的三种简单方法

JavaScript对象转数组的三种简单方法

大家好&#xff01;今天我们要聊的是JavaScript中一个非常实用的技巧——将对象转换为数组。 方法1&#xff1a;使用Object.keys()和Array.map() 首先介绍一种基础但非常实用的方法&#xff0c;就是通过Object.keys()获取对象的键&#xff0c;然后用Array.map()把这些键对应的值…
阅读更多...
C++ primer plus 第17 章 输入、输出和文件：文件输入和输出01

C++ primer plus 第17 章 输入、输出和文件：文件输入和输出01

C primer plus 第17 章 输入、输出和文件&#xff1a;文件输入和输出01 C primer plus 第17 章 输入、输出和文件&#xff1a;文件输入和输出01 文章目录 C primer plus 第17 章 输入、输出和文件&#xff1a;文件输入和输出0117.4 文件输入和输出17.4.1 简单的文件 1/0程序清…
阅读更多...
商家转账到零钱分销返佣申请方案及驳回处理办法

商家转账到零钱分销返佣申请方案及驳回处理办法

分销返佣场景是商家申请最多的场景&#xff0c;因而申请被驳回也是最多的&#xff0c;根据我们上万次成功开通商家转账到零钱的经验&#xff0c;当商家转账到零钱的分销返佣场景被驳回时&#xff0c;按照以下步骤&#xff0c;商家都可以快速过审&#xff1a; 一、分析驳回原因 …
阅读更多...
C Primer Plus 第6章——第一篇

C Primer Plus 第6章——第一篇

你该逆袭了 第6章:重点摘录 零、本章内容介绍一、while 循环1、程序注释&#xff08;1&#xff09;伪代码 2、C 风格读取循环 二、while 语句1、终止 while 循环2、语法要点 三、用 关系运算符 和 表达式 比较大小1、fabs( ) 函数 比较 浮点数(1) fabs( ) 函数 2、什么是 真&am…
阅读更多...
世界人口过亿的一级行政区分布

世界人口过亿的一级行政区分布

世界国人口已经突破80亿&#xff0c;人口过亿的国家也有14个&#xff0c;分别是中国、俄罗斯、巴西、墨西哥&#xff0c;美国、日本、印度、巴基斯坦、印度尼西亚、尼日利亚、孟加拉国、埃塞俄比亚、菲律宾、埃及。 那么作为国家的一级行政区人口过亿的区域有那些呢?这里就来…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023