萬物皆可 Serverless 之使用雲函數 Timer 觸發器實現天天自動定時打卡

時間  2020-06-04
標籤 萬物 皆可 serverless 使用 函數 timer 觸發器 實現 天天 自動 定時 打卡 简体版
原文   原文鏈接

不曉得你們有沒有遇到過定時打卡的需求，好比商品秒殺，火車票定時開售、每日健康打卡等。這時候咱們每每能夠經過一些技術手段，編寫一些自動化操做的腳本，來實現定時自動打卡的操做。javascript

本文來自 Serverless 社區用戶「乂乂又又」供稿java

固然本文並不探討如何編寫自動化的操做腳本，而是和你們介紹一下如何使用騰訊雲函數的 Timer 觸發器實現定時任務，來快速、穩定、低成本地實現一些 fancy 的操做（騷操做）python

效果展現

  • 每日健康信息自動更新

每日健康信息自動更新

  • 每日定時數據報告

每日定時數據報告

能夠看到，定時任務搭配郵箱發送雲函數運行結果，用起來仍是蠻舒服的，還能夠給本身作一個每日科技資訊推送、數據報告之類的小玩意，自娛自樂。其餘的用途請你們大開腦洞，自行腦補吧~git

實戰教程

1. 新建雲函數

新建函數

運行環境咱們選擇 python3，模板函數選擇定時撥測，而後點擊下一步github

定時撥測模板函數

模板函數的描述裏寫着「本示例代碼的功能是定時撥測 URL 列表中的地址，並經過郵件發送告警」express

而這正是咱們想要的實現的功能，不過這個模板函數的郵件發送有點問題，咱們稍後會詳細說明json

2. 模板函數分析

下面咱們來分析一下這段示例代碼瀏覽器

# -*- coding: utf8 -*-
import sys
import os

sys.path.insert(0, os.path.dirname(os.path.abspath(__file__)) + "/..")

import logging
import json
import requests
from email.mime.text import MIMEText
from email.header import Header
import smtplib

logger = logging.getLogger()
logger.setLevel(logging.DEBUG)

# Third-party SMTP service for sending alert emails. 第三方 SMTP 服務，用於發送告警郵件
mail_host = "smtp.qq.com"       # SMTP server, such as QQ mailbox, need to open SMTP service in the account. SMTP服務器,如QQ郵箱，須要在帳戶裏開啓SMTP服務
mail_user = "XXXXXXXXX@qq.com"  # Username 用戶名
mail_pass = "****************"  # Password, SMTP service password. 口令，SMTP服務密碼
mail_port = 465  # SMTP service port. SMTP服務端口

# The URL address need to dial test. 須要撥測的URL地址
test_url_list = [
    "http://www.baidu.com",
    "http://www.qq.com",
    "http://wrong.tencent.com",
    "http://unkownurl.com"
]

# The notification list of alert emails. 告警郵件通知列表
email_notify_list = {
    "XXXXXXXXX@qq.com",
    "XXXXXXXXX@qq.com"
}


def sendEmail(fromAddr, toAddr, subject, content):
    sender = fromAddr
    receivers = [toAddr]
    message = MIMEText(content, 'plain', 'utf-8')
    message['From'] = Header(fromAddr, 'utf-8')
    message['To'] = Header(toAddr, 'utf-8')
    message['Subject'] = Header(subject, 'utf-8')
    try:
        smtpObj = smtplib.SMTP_SSL(mail_host, mail_port)
        smtpObj.login(mail_user, mail_pass)
        smtpObj.sendmail(sender, receivers, message.as_string())
        print("send email success")
        return True
    except smtplib.SMTPException as e:
        print(e)
        print("Error: send email fail")
        return False


def test_url(url_list):
    errorinfo = [serverless]
    for url in url_list:
        resp = None
        try:
            resp = requests.get(url, timeout=3)
            print (resp)
        except (
        requests.exceptions.Timeout, requests.exceptions.ConnectionError, requests.exceptions.ConnectTimeout) as e:
            logger.warn("request exceptions:" + str(e))
            errorinfo.append("Access " + url + " timeout")
        else:
            if resp.status_code >= 400:
                logger.warn("response status code fail:" + str(resp.status_code))
                errorinfo.append("Access " + url + " fail, status code:" + str(resp.status_code))
    if len(errorinfo) != 0:
        body = "\r\n".join(errorinfo)
        subject = "Please note: PlayCheck Error"
        for toAddr in email_notify_list:
            print ("send message [%s] to [%s]" % (body, toAddr))
            sendEmail(mail_user, toAddr, subject, body)


def main_handler(event, context):
    test_url(test_url_list)


if __name__ == '__main__':
    main_handler("", "")

這裏要講一下雲函數的執行入口，服務器

這個模板函數的默認入口是 main\_handler(event, context) 這個函數，架構

這個入口函數是能夠自行配置的，具體配置方法能夠翻看官方的文檔

def main_handler(event, context):
    test_url(test_url_list)

另外這裏的 py 文件的主函數入口，其實是能夠缺省的。這裏加上應該是爲了方便本地調試和運行函數。

if __name__ == '__main__':
    main_handler("", "")

而後看一下依賴庫的導入部分

import requests
from email.mime.text import MIMEText
from email.header import Header
import smtplib

注意到有 import requests，但本地文件並無 requests 庫，說明騰訊雲函數的運行環境中已經安裝了 requests 庫，並不須要咱們再手動上傳添加 requests 依賴。

def test_url(url_list):
    errorinfo = [serverless]
    for url in url_list:
        resp = None
        try:
            resp = requests.get(url, timeout=3)
            print (resp)
        except (
        requests.exceptions.Timeout, requests.exceptions.ConnectionError, requests.exceptions.ConnectTimeout) as e:
            logger.warn("request exceptions:" + str(e))
            errorinfo.append("Access " + url + " timeout")
        else:
            if resp.status_code >= 400:
                logger.warn("response status code fail:" + str(resp.status_code))
                errorinfo.append("Access " + url + " fail, status code:" + str(resp.status_code))
    if len(errorinfo) != 0:
        body = "\r\n".join(errorinfo)
        subject = "Please note: PlayCheck Error"
        for toAddr in email_notify_list:
            print ("send message [%s] to [%s]" % (body, toAddr))
            sendEmail(mail_user, toAddr, subject, body)

這裏的 test\_url 函數的思路很是清晰，首先請求 url\_list 內的目標網頁，若是請求超時或者出現錯誤碼就會記錄下 errorinfo。

當 errorinfo 列表非空時，也就是有連接的訪問出現問題時就會調用 sendEmail 函數

def sendEmail(fromAddr, toAddr, subject, content):
    sender = fromAddr
    receivers = [toAddr]
    message = MIMEText(content, 'plain', 'utf-8')
    message['From'] = Header(fromAddr, 'utf-8')
    message['To'] = Header(toAddr, 'utf-8')
    message['Subject'] = Header(subject, 'utf-8')
    try:
        smtpObj = smtplib.SMTP_SSL(mail_host, mail_port)
        smtpObj.login(mail_user, mail_pass)
        smtpObj.sendmail(sender, receivers, message.as_string())
        print("send email success")
        return True
    except smtplib.SMTPException as e:
        print(e)
        print("Error: send email fail")
        return False

sendEmail 函數負責登陸郵箱併發送 errorinfo 郵件提醒

smtpObj = smtplib.SMTP_SSL(mail_host, mail_port)
smtpObj.login(mail_user, mail_pass)
smtpObj.sendmail(sender, receivers, message.as_string())

下面咱們再看一下雲函數的配置文件

定時器配置

注意圖中畫紅圈的部分

"CronExpression": "* */1 * * * * *",

這是 Cron 表達式，用來描述定時任務開始執行時間用的，這裏的 \* \*/1 \* \* \* \* \* 表示每分鐘執行一次雲函數，以達到網站監控撥測的功能。有關 Cron 表達式的具體用法可翻閱騰訊雲官方文檔。

以上就是整個撥測示例雲函數的工做流程。下面就讓咱們來照葫蘆畫瓢編寫本身的雲函數吧。

3. 請求數據分析

喜聞樂見的抓包環節，看看打卡的時候時手機應用都和服務器交流了些啥

應用數據首頁

點進去看一下

登錄應用

OK，這裏咱們已經看到了應用的登陸過程，這裏提交了 username，password 和 type 三個參數，分別對應咱們的用戶名，登錄密碼和用戶類型，後面咱們只須要把這些數據從新發送給服務器就能夠模擬登錄 App 了

提交信息

這裏就是向服務器發送咱們填寫的健康信息，一會咱們再把這些信息一股腦再從新拋給服務器就行了

4. 編寫雲函數

根據上面的分析，直接上代碼

def myHealth(user, pwd, email):
    errorinfo = [serverless]
    s = requests.Session()  # 新建一個request對象
    data = {  # 登錄信息
        'username': user,
        'password': pwd,
        'type': 'student',
    }
    r = s.post(server+'/authentication/login', json=data)  # 登陸
    if r.json()['ok']:
        errorinfo.append('登錄成功')
    else:
        s.close()
        errorinfo.append('登錄失敗')
        return
    data = {  # 健康信息
        "home": "在家",
        "address": "",
        "keepInHome": "否",
        "keepInHomeDate": 'null',
        "contact": "否",
        "health": "否",
        "familyNCP": "否",
        "fever": "否",
        "feverValue": "",
        "cough": "否",
        "diarrhea": "否",
        "homeInHubei": "否",
        "arriveHubei": "無",
        "travel": "無",
        "remark": "無",
        "submitCount": '0'
    }
    r = s.post(server+'/student/healthInfo/save', json=data)  # 提交健康信息
    if r.json()['ok']:
        errorinfo.append('提交健康信息成功')
    else:
        errorinfo.append('提交健康信息失敗：'+r.json()['message'])
    s.close()  # 關閉鏈接
    emailTask(errorinfo, email)  # 發送郵件

嗯，替換一下模板函數裏面的 test\_url 函數就 ok 了

不過前面我有提到郵件發送有問題，下面咱們來看下 sendemai 函數裏郵件內容編碼部分

message['From'] = Header(fromAddr, 'utf-8')
    message['To'] = Header(toAddr, 'utf-8')
    message['Subject'] = Header(subject, 'utf-8')

這裏的收件人，發件人和主題信息都通過了 Header(string, 'utf-8') 來編碼。不過在我用 163 郵箱發信時，這種方法只能本身給本身的郵箱發郵件，給別人發會被郵件系統當成垃圾郵件發送失敗。因此若是你須要給其餘郵箱發郵件的話，這裏須要去掉編碼，改爲

message['From'] = fromAddr
    message['To'] = toAddr
    message['Subject'] = subject

這樣就能夠正常發送郵件了

5. 設置觸發器

OK，咱們把修改好的雲函數保存一下

配置函數

而後把內存改到 64mb，超時時間給個 3s 便可

添加觸發器

最後添加定時觸發器，這裏咱們選擇自定義觸發週期。

Cron 表達式 0 0 6 \* \* \* \* 表明天天早上 6 點觸發一次，注意千萬不要寫成 \* \* 6 \* \* \* \* ，否則將會在天天的 6-7 點內每秒觸發一次。這樣的話就，畫面太美不敢想象，哈哈哈 ~

寫在最後

以上，想必如今你已經 get 瞭如何使用 Timer 觸發器來觸發雲函數了，何不趕快本身動手嘗試一下呢？

發揮你的想象力，試着作些有趣又有用的小東西吧！本文僅供學習交流之用途，不要學來幹壞事哦~

Serverless Framework 30 天試用計劃

咱們誠邀您來體驗最便捷的 Serverless 開發和部署方式。在試用期內，相關聯的產品及服務均提供免費資源和專業的技術支持，幫助您的業務快速、便捷地實現 Serverless！

詳情可查閱：Serverless Framework 試用計劃

One More Thing

3 秒你能作什麼？喝一口水，看一封郵件，仍是 —— 部署一個完整的 Serverless 應用？

複製連接至 PC 瀏覽器訪問：https://serverless.cloud.tencent.com/deploy/express

3 秒極速部署，當即體驗史上最快的 Serverless HTTP 實戰開發！

傳送門：

歡迎訪問：Serverless 中文網，您能夠在 最佳實踐 裏體驗更多關於 Serverless 應用的開發！

推薦閱讀：《Serverless 架構：從原理、設計到項目實戰》

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程