腾讯云AI代码助手初体验：3步打造AI日报机器人，每天自动推送行业动态！

def send_to_feishu(content, webhook_url):
    """
    发送消息到飞书机器人
    :param content: 要发送的Markdown内容
    :param webhook_url: 飞书机器人Webhook地址
    :return: 是否发送成功
    """
    headers = {
        "Content-Type": "application/json"
    }
    
    payload = {
        "msg_type": "interactive",
        "card": {
            "config": {
                "wide_screen_mode": True
            },
            "elements": [{
                "tag": "div",
                "text": {
                    "content": content,
                    "tag": "lark_md"
                }
            }],
            "header": {
                "title": {
                    "content": f"AI日报 {datetime.now().strftime('%Y-%m-%d')}",
                    "tag": "plain_text"
                }
            }
        }
    }

    try:
        response = requests.post(webhook_url, json=payload, headers=headers)
        response.raise_for_status()
        return response.status_code == 200
    except requests.exceptions.RequestException as e:
        print(f"飞书消息发送失败: {str(e)}")
        return False
        

## 代码示例
def main():
    # 从环境变量获取飞书Webhook地址
    load_dotenv()  # 加载.env文件（如果有）p
    feishu_webhook = os.getenv("FEISHU_WEBHOOK")
    print(feishu_webhook)
    all_news = {}
    for name, url in NEWS_FEEDS.items():
        print(f"正在抓取 {name}...")
        all_news[name] = fetch_news(url)
    
    report = generate_daily_report(all_news)
    
    # 保存报告
    filename = f"AI_Daily_Report_{datetime.now().strftime('%Y%m%d')}.md"
    with open(filename, "w", encoding="utf-8") as f:
        f.write(report)
    print(f"日报已生成：{filename}")

    # 发送到飞书
    if feishu_webhook:
        if send_to_feishu(report, feishu_webhook):
            print("已成功推送至飞书")
        else:
            print("飞书推送失败")
    else:
        print("未配置飞书Webhook，跳过推送")

def main_job():
    """包装主函数用于定时任务"""
    try:
        print("\n" + "="*40)
        print(f"开始执行每日任务 {datetime.now()}")
        main()
        print(f"任务完成 {datetime.now()}")
        print("="*40 + "\n")
    except Exception as e:
        print(f"任务执行失败: {str(e)}")
        # 这里可以添加错误通知逻辑

def setup_scheduler():
    """配置定时任务调度器"""
    scheduler = BlockingScheduler(timezone=pytz.timezone('Asia/Shanghai'))
    
    # 每天上午9点执行
    trigger = CronTrigger(
        year="*", month="*", day="*",
        hour=9, minute=0, second=0
    )
    
    scheduler.add_job(
        main_job,
        trigger=trigger,
        name="每日AI报告生成",
        max_instances=1,
        misfire_grace_time=300
    )
    
    return scheduler


if __name__ == "__main__":
    print("首次手动执行...")
    main_job()
    
    # 启动定时任务
    print("启动定时任务，每天北京时间09:00自动执行...")
    try:
        scheduler = setup_scheduler()
        scheduler.start()
    except (KeyboardInterrupt, SystemExit):
        print("\n定时任务已终止")
    except Exception as e:
        print(f"调度器启动失败: {str(e)}")

    #print(extract_chinese_summary(requests.get("https://www.jiqizhixin.com/articles/2023-03-07-11").text))