阿里云函数计算FC实现网站定时任务与自动化的完全指南

{
  "triggerTime": "2023-12-26T07:49:00Z",
  "triggerName": "timer-trigger",
  "payload": "awesome-fc"
}

import json
import requests
import smtplib
from email.mime.text import MIMEText
from email.header import Header
import os
import logging
logger = logging.getLogger()
logger.setLevel(logging.INFO)
WEATHER_API_URL = "https://restapi.amap.com/v3/weather/weatherInfo"
WEATHER_API_KEY = os.environ.get('WEATHER_API_KEY')
MAIL_FROM = os.environ.get('MAIL_USERNAME')
MAIL_PASSWORD = os.environ.get('MAIL_PASSWORD')
MAIL_TO = os.environ.get('MAIL_TO')
def get_weather(city_code):
    """获取天气信息"""
    params = {
        'key': WEATHER_API_KEY,
        'city': city_code,
        'extensions': 'base'
    }
    try:
        response = requests.get(WEATHER_API_URL, params=params, timeout=10)
        if response.status_code == 200:
            data = response.json()
            if data.get('status') == '1':
                return data.get('lives', [{}])[0]
    except Exception as e:
        logger.error(f"获取天气失败: {e}")
    return None
def send_email(subject, content):
    """发送邮件"""
    try:
        msg = MIMEText(content, 'plain', 'utf-8')
        msg['Subject'] = Header(subject, 'utf-8')
        msg['From'] = MAIL_FROM
        msg['To'] = MAIL_TO
        
        server = smtplib.SMTP_SSL('smtp.qq.com', 465)
        server.login(MAIL_FROM, MAIL_PASSWORD)
        server.sendmail(MAIL_FROM, [MAIL_TO], msg.as_string())
        server.quit()
        logger.info("邮件发送成功")
        return True
    except Exception as e:
        logger.error(f"邮件发送失败: {e}")
        return False
def handler(event, context):
    """
    FC函数入口
    event: 定时触发器传入的事件
    context: 函数计算上下文
    """
    logger.info(f"定时任务触发，事件: {json.dumps(event)}")
    
    # 获取天气
    weather = get_weather('110101')  # 北京
    if weather:
        content = f"今日天气: {weather.get('weather')}\n温度: {weather.get('temperature')}℃\n风向: {weather.get('winddirection')}\n风力: {weather.get('windpower')}级"
        send_email('每日天气推送', content)
        return {
            'statusCode': 200,
            'body': json.dumps({'message': '天气推送成功'})
        }
    else:
        return {
            'statusCode': 500,
            'body': json.dumps({'message': '获取天气失败'})
        }

const crypto = require('crypto');
const axios = require('axios');
exports.handler = async function(event, context, callback) {
    console.log('定时任务触发:', JSON.stringify(event));
    
    try {
        // 获取当前时间
        const now = new Date();
        const timestamp = now.toISOString();
        
        // 业务逻辑处理
        const result = await processData();
        
        return {
            statusCode: 200,
            body: JSON.stringify({
                message: '定时任务执行成功',
                timestamp: timestamp,
                data: result
            })
        };
    } catch (error) {
        console.error('定时任务执行失败:', error);
        return {
            statusCode: 500,
            body: JSON.stringify({
                message: '定时任务执行失败',
                error: error.message
            })
        };
    }
};
async function processData() {
    // 在这里实现具体的业务逻辑
    // 例如：数据库备份、数据同步、报表生成等
    return { processed: true, count: 100 };
}

package com.example.fc;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
public class TimerTaskHandler {
    
    public JSONObject handleRequest(JSONObject event, Context context) {
        context.getLogger().info("定时任务触发: " + event.toJSONString());
        
        try {
            // 执行业务逻辑
            String result = executeTask();
            
            JSONObject response = new JSONObject();
            response.put("statusCode", 200);
            response.put("message", "定时任务执行成功");
            response.put("result", result);
            return response;
        } catch (Exception e) {
            context.getLogger().error("定时任务执行失败: " + e.getMessage());
            JSONObject response = new JSONObject();
            response.put("statusCode", 500);
            response.put("message", "定时任务执行失败");
            response.put("error", e.getMessage());
            return response;
        }
    }
    
    private String executeTask() {
        // 实现具体的业务逻辑
        return "Task completed at " + System.currentTimeMillis();
    }
}

package main
import (
    "context"
    "encoding/json"
    "fmt"
    "log"
    "time"
    "github.com/aliyun/fc-runtime-go-sdk/fc"
)
type Event struct {
    TriggerTime string `json:"triggerTime"`
    TriggerName string `json:"triggerName"`
    Payload     string `json:"payload"`
}
type Response struct {
    StatusCode int    `json:"statusCode"`
    Message    string `json:"message"`
    Timestamp  string `json:"timestamp"`
}
func HandleRequest(ctx context.Context, event Event) (Response, error) {
    log.Printf("定时任务触发: %+v\n", event)
    
    // 执行业务逻辑
    result := executeTask()
    
    return Response{
        StatusCode: 200,
        Message:    "定时任务执行成功: " + result,
        Timestamp:  time.Now().Format(time.RFC3339),
    }, nil
}
func executeTask() string {
    // 实现具体的业务逻辑
    return fmt.Sprintf("任务完成于 %s", time.Now().Format("2006-01-02 15:04:05"))
}
func main() {
    fc.Start(HandleRequest)
}