Telegram机器人进阶实战从天气推送到群组管理的创意玩法如果你已经创建了一个只会回复你好的Telegram机器人现在正思考如何让它变得更实用这篇文章将为你打开一扇新世界的大门。我们将探索几个极具实用价值的机器人功能实现方案让你的机器人从玩具变成真正的工具。1. 调用第三方API实现天气查询功能天气查询是机器人最实用的功能之一。通过集成OpenWeatherMap这样的天气API你的机器人可以成为朋友群组中的气象预报员。首先你需要在OpenWeatherMap官网注册并获取API密钥。这个密钥将允许你每天进行一定次数的免费天气查询。有了这个密钥后我们可以开始编写天气查询功能的核心代码。import requests from telegram import Update from telegram.ext import Updater, CommandHandler, CallbackContext def get_weather(api_key, city): base_url http://api.openweathermap.org/data/2.5/weather params { q: city, appid: api_key, units: metric, lang: zh_cn } response requests.get(base_url, paramsparams) data response.json() return data def weather(update: Update, context: CallbackContext) - None: if not context.args: update.message.reply_text(请指定城市名称例如/weather 北京) return city .join(context.args) weather_data get_weather(YOUR_API_KEY, city) if weather_data.get(cod) ! 200: update.message.reply_text(无法获取该城市的天气信息) return description weather_data[weather][0][description] temp weather_data[main][temp] humidity weather_data[main][humidity] wind_speed weather_data[wind][speed] reply ( f{city}的天气情况\n f天气状况{description}\n f当前温度{temp}°C\n f湿度{humidity}%\n f风速{wind_speed}米/秒 ) update.message.reply_text(reply)提示在实际部署时记得将YOUR_API_KEY替换为你从OpenWeatherMap获取的真实API密钥并考虑将密钥存储在环境变量中而非直接硬编码在代码里。这个功能实现后用户只需在聊天中输入/weather 城市名机器人就会返回详细的天气信息。你可以进一步扩展这个功能比如添加多语言支持提供更详细的天气预报如未来几天的预报实现自动位置检测根据用户发送的位置信息返回天气2. 实现定时任务每日新闻推送定时推送功能可以让你的机器人主动向用户或群组发送信息而不需要用户先发起交互。这在新闻简报、每日提醒等场景中特别有用。Python的apscheduler库非常适合实现这种定时任务功能。下面是一个实现每天上午8点自动发送新闻摘要的例子from apscheduler.schedulers.background import BackgroundScheduler from telegram.ext import Updater def fetch_news(): # 这里应该是获取新闻的实际代码 # 可以使用NewsAPI或其他新闻源 return 今日头条\n1. 科技领域新突破...\n2. 国际形势最新进展... def send_news(context): news_text fetch_news() # 这里假设我们有一个存储了所有订阅用户的列表 for chat_id in subscribed_users: context.bot.send_message(chat_idchat_id, textnews_text) def setup_scheduler(updater): scheduler BackgroundScheduler() scheduler.add_job( send_news, cron, hour8, minute0, args[updater] ) scheduler.start() # 在main函数中添加 def main(): updater Updater(YOUR_BOT_TOKEN) setup_scheduler(updater) # ...其他代码这个定时任务系统可以扩展出许多实用功能个性化推送根据用户偏好发送不同类型的新闻多时段推送不仅限于早晨可以设置午间简报、晚间摘要等互动订阅添加命令让用户选择接收哪些类型的推送注意在实现定时推送功能时要确保你的机器人代码是长期运行的。如果脚本停止运行定时任务也会停止。考虑使用云服务器或PaaS平台来保持机器人24/7在线。3. 群组管理功能实现一个管理良好的Telegram群组需要一些自动化工具来处理常见任务。我们可以为机器人添加以下群组管理功能3.1 新成员欢迎消息当新成员加入群组时自动发送欢迎消息并介绍群规这能显著提升新成员的归属感。from telegram.ext import MessageHandler, Filters def welcome_new_member(update: Update, context: CallbackContext) - None: for member in update.message.new_chat_members: welcome_text ( f欢迎 {member.full_name} 加入群组\n\n 请阅读我们的群规\n 1. 保持友善禁止人身攻击\n 2. 禁止发送无关广告\n 3. 技术讨论请尽量详细描述问题 ) update.message.reply_text(welcome_text) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加欢迎消息处理器 updater.dispatcher.add_handler( MessageHandler(Filters.status_update.new_chat_members, welcome_new_member) ) # ...其他代码3.2 关键词过滤系统维护群组环境常常需要过滤不当言论。我们可以实现一个简单的关键词过滤系统banned_keywords [攻击性词语, 广告链接, 敏感话题] def filter_messages(update: Update, context: CallbackContext) - None: message_text update.message.text.lower() if update.message.text else for keyword in banned_keywords: if keyword in message_text: update.message.delete() update.message.reply_text( f{update.message.from_user.full_name}, 你的消息包含不当内容已被删除。 ) break def main(): updater Updater(YOUR_BOT_TOKEN) # 添加消息过滤器 updater.dispatcher.add_handler( MessageHandler(Filters.text (~Filters.command), filter_messages) ) # ...其他代码3.3 群组数据统计了解群组活跃度对于管理很有帮助。我们可以让机器人定期统计并报告群组活动情况from datetime import datetime, timedelta group_stats { messages_today: 0, new_members_week: 0, last_reset: datetime.now() } def count_message(update: Update, context: CallbackContext) - None: # 每天重置计数器 if datetime.now() - group_stats[last_reset] timedelta(days1): group_stats[messages_today] 0 group_stats[last_reset] datetime.now() group_stats[messages_today] 1 def stats_command(update: Update, context: CallbackContext) - None: stats_text ( 群组统计数据\n f今日消息数{group_stats[messages_today]}\n f本周新成员{group_stats[new_members_week]} ) update.message.reply_text(stats_text) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加消息计数器 updater.dispatcher.add_handler( MessageHandler(Filters.text (~Filters.command), count_message) ) # 添加统计命令 updater.dispatcher.add_handler(CommandHandler(stats, stats_command)) # ...其他代码4. 进阶功能与创意扩展有了上述基础功能后你可以考虑实现更复杂的交互功能让机器人更加智能和实用。4.1 交互式问卷调查在群组中发起快速投票或问卷调查是收集意见的好方法。下面是一个简单的投票系统实现from telegram import InlineKeyboardButton, InlineKeyboardMarkup active_polls {} def start_poll(update: Update, context: CallbackContext) - None: if not context.args: update.message.reply_text(使用方法/poll 问题 选项1 选项2 ...) return question context.args[0] options context.args[1:] keyboard [ [InlineKeyboardButton(option, callback_datafvote_{i})] for i, option in enumerate(options) ] reply_markup InlineKeyboardMarkup(keyboard) message update.message.reply_text( f投票{question}, reply_markupreply_markup ) # 存储投票数据 active_polls[message.message_id] { question: question, options: options, votes: [0] * len(options) } def button_callback(update: Update, context: CallbackContext) - None: query update.callback_query poll_id query.message.message_id if poll_id not in active_polls: return poll active_polls[poll_id] option_index int(query.data.split(_)[1]) poll[votes][option_index] 1 # 更新消息显示投票结果 results \n.join( f{opt}: {vote}票 for opt, vote in zip(poll[options], poll[votes]) ) query.edit_message_text( textf{poll[question]}\n\n当前结果\n{results} ) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加投票命令 updater.dispatcher.add_handler(CommandHandler(poll, start_poll)) # 添加按钮回调 updater.dispatcher.add_handler(CallbackQueryHandler(button_callback)) # ...其他代码4.2 个性化用户交互通过记忆用户偏好和交互历史你可以打造更个性化的机器人体验user_preferences {} def set_preference(update: Update, context: CallbackContext) - None: if len(context.args) 2: update.message.reply_text(使用方法/setpref 偏好名 值) return user_id update.message.from_user.id pref_name context.args[0] pref_value .join(context.args[1:]) if user_id not in user_preferences: user_preferences[user_id] {} user_preferences[user_id][pref_name] pref_value update.message.reply_text(f已设置 {pref_name} 为 {pref_value}) def get_preference(update: Update, context: CallbackContext) - None: if not context.args: update.message.reply_text(使用方法/getpref 偏好名) return user_id update.message.from_user.id pref_name context.args[0] if user_id in user_preferences and pref_name in user_preferences[user_id]: update.message.reply_text( f{pref_name}: {user_preferences[user_id][pref_name]} ) else: update.message.reply_text(未找到该偏好设置) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加偏好设置命令 updater.dispatcher.add_handler(CommandHandler(setpref, set_preference)) updater.dispatcher.add_handler(CommandHandler(getpref, get_preference)) # ...其他代码4.3 与外部服务集成将机器人与其他流行服务集成可以大幅扩展其功能。例如与GitHub集成实现issue跟踪def github_issue(update: Update, context: CallbackContext) - None: if len(context.args) 2: update.message.reply_text(使用方法/issue 仓库名 问题标题 问题描述) return repo context.args[0] title context.args[1] body .join(context.args[2:]) if len(context.args) 2 else # 这里应该是实际调用GitHub API创建issue的代码 # 需要GitHub个人访问令牌 update.message.reply_text(f已在 {repo} 创建issue: {title}) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加GitHub issue命令 updater.dispatcher.add_handler(CommandHandler(issue, github_issue)) # ...其他代码在实际项目中我发现最实用的机器人功能往往是那些解决特定小痛点的功能而不是试图做所有事情的全能型机器人。比如一个专门用来快速转换时区的机器人或者一个能根据食谱名称返回配料清单的机器人在实际使用中会比功能复杂但不精专的机器人更有价值。
除了自动回复，你的Telegram机器人还能这么玩：从天气推送到群组管理实战
Telegram机器人进阶实战从天气推送到群组管理的创意玩法如果你已经创建了一个只会回复你好的Telegram机器人现在正思考如何让它变得更实用这篇文章将为你打开一扇新世界的大门。我们将探索几个极具实用价值的机器人功能实现方案让你的机器人从玩具变成真正的工具。1. 调用第三方API实现天气查询功能天气查询是机器人最实用的功能之一。通过集成OpenWeatherMap这样的天气API你的机器人可以成为朋友群组中的气象预报员。首先你需要在OpenWeatherMap官网注册并获取API密钥。这个密钥将允许你每天进行一定次数的免费天气查询。有了这个密钥后我们可以开始编写天气查询功能的核心代码。import requests from telegram import Update from telegram.ext import Updater, CommandHandler, CallbackContext def get_weather(api_key, city): base_url http://api.openweathermap.org/data/2.5/weather params { q: city, appid: api_key, units: metric, lang: zh_cn } response requests.get(base_url, paramsparams) data response.json() return data def weather(update: Update, context: CallbackContext) - None: if not context.args: update.message.reply_text(请指定城市名称例如/weather 北京) return city .join(context.args) weather_data get_weather(YOUR_API_KEY, city) if weather_data.get(cod) ! 200: update.message.reply_text(无法获取该城市的天气信息) return description weather_data[weather][0][description] temp weather_data[main][temp] humidity weather_data[main][humidity] wind_speed weather_data[wind][speed] reply ( f{city}的天气情况\n f天气状况{description}\n f当前温度{temp}°C\n f湿度{humidity}%\n f风速{wind_speed}米/秒 ) update.message.reply_text(reply)提示在实际部署时记得将YOUR_API_KEY替换为你从OpenWeatherMap获取的真实API密钥并考虑将密钥存储在环境变量中而非直接硬编码在代码里。这个功能实现后用户只需在聊天中输入/weather 城市名机器人就会返回详细的天气信息。你可以进一步扩展这个功能比如添加多语言支持提供更详细的天气预报如未来几天的预报实现自动位置检测根据用户发送的位置信息返回天气2. 实现定时任务每日新闻推送定时推送功能可以让你的机器人主动向用户或群组发送信息而不需要用户先发起交互。这在新闻简报、每日提醒等场景中特别有用。Python的apscheduler库非常适合实现这种定时任务功能。下面是一个实现每天上午8点自动发送新闻摘要的例子from apscheduler.schedulers.background import BackgroundScheduler from telegram.ext import Updater def fetch_news(): # 这里应该是获取新闻的实际代码 # 可以使用NewsAPI或其他新闻源 return 今日头条\n1. 科技领域新突破...\n2. 国际形势最新进展... def send_news(context): news_text fetch_news() # 这里假设我们有一个存储了所有订阅用户的列表 for chat_id in subscribed_users: context.bot.send_message(chat_idchat_id, textnews_text) def setup_scheduler(updater): scheduler BackgroundScheduler() scheduler.add_job( send_news, cron, hour8, minute0, args[updater] ) scheduler.start() # 在main函数中添加 def main(): updater Updater(YOUR_BOT_TOKEN) setup_scheduler(updater) # ...其他代码这个定时任务系统可以扩展出许多实用功能个性化推送根据用户偏好发送不同类型的新闻多时段推送不仅限于早晨可以设置午间简报、晚间摘要等互动订阅添加命令让用户选择接收哪些类型的推送注意在实现定时推送功能时要确保你的机器人代码是长期运行的。如果脚本停止运行定时任务也会停止。考虑使用云服务器或PaaS平台来保持机器人24/7在线。3. 群组管理功能实现一个管理良好的Telegram群组需要一些自动化工具来处理常见任务。我们可以为机器人添加以下群组管理功能3.1 新成员欢迎消息当新成员加入群组时自动发送欢迎消息并介绍群规这能显著提升新成员的归属感。from telegram.ext import MessageHandler, Filters def welcome_new_member(update: Update, context: CallbackContext) - None: for member in update.message.new_chat_members: welcome_text ( f欢迎 {member.full_name} 加入群组\n\n 请阅读我们的群规\n 1. 保持友善禁止人身攻击\n 2. 禁止发送无关广告\n 3. 技术讨论请尽量详细描述问题 ) update.message.reply_text(welcome_text) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加欢迎消息处理器 updater.dispatcher.add_handler( MessageHandler(Filters.status_update.new_chat_members, welcome_new_member) ) # ...其他代码3.2 关键词过滤系统维护群组环境常常需要过滤不当言论。我们可以实现一个简单的关键词过滤系统banned_keywords [攻击性词语, 广告链接, 敏感话题] def filter_messages(update: Update, context: CallbackContext) - None: message_text update.message.text.lower() if update.message.text else for keyword in banned_keywords: if keyword in message_text: update.message.delete() update.message.reply_text( f{update.message.from_user.full_name}, 你的消息包含不当内容已被删除。 ) break def main(): updater Updater(YOUR_BOT_TOKEN) # 添加消息过滤器 updater.dispatcher.add_handler( MessageHandler(Filters.text (~Filters.command), filter_messages) ) # ...其他代码3.3 群组数据统计了解群组活跃度对于管理很有帮助。我们可以让机器人定期统计并报告群组活动情况from datetime import datetime, timedelta group_stats { messages_today: 0, new_members_week: 0, last_reset: datetime.now() } def count_message(update: Update, context: CallbackContext) - None: # 每天重置计数器 if datetime.now() - group_stats[last_reset] timedelta(days1): group_stats[messages_today] 0 group_stats[last_reset] datetime.now() group_stats[messages_today] 1 def stats_command(update: Update, context: CallbackContext) - None: stats_text ( 群组统计数据\n f今日消息数{group_stats[messages_today]}\n f本周新成员{group_stats[new_members_week]} ) update.message.reply_text(stats_text) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加消息计数器 updater.dispatcher.add_handler( MessageHandler(Filters.text (~Filters.command), count_message) ) # 添加统计命令 updater.dispatcher.add_handler(CommandHandler(stats, stats_command)) # ...其他代码4. 进阶功能与创意扩展有了上述基础功能后你可以考虑实现更复杂的交互功能让机器人更加智能和实用。4.1 交互式问卷调查在群组中发起快速投票或问卷调查是收集意见的好方法。下面是一个简单的投票系统实现from telegram import InlineKeyboardButton, InlineKeyboardMarkup active_polls {} def start_poll(update: Update, context: CallbackContext) - None: if not context.args: update.message.reply_text(使用方法/poll 问题 选项1 选项2 ...) return question context.args[0] options context.args[1:] keyboard [ [InlineKeyboardButton(option, callback_datafvote_{i})] for i, option in enumerate(options) ] reply_markup InlineKeyboardMarkup(keyboard) message update.message.reply_text( f投票{question}, reply_markupreply_markup ) # 存储投票数据 active_polls[message.message_id] { question: question, options: options, votes: [0] * len(options) } def button_callback(update: Update, context: CallbackContext) - None: query update.callback_query poll_id query.message.message_id if poll_id not in active_polls: return poll active_polls[poll_id] option_index int(query.data.split(_)[1]) poll[votes][option_index] 1 # 更新消息显示投票结果 results \n.join( f{opt}: {vote}票 for opt, vote in zip(poll[options], poll[votes]) ) query.edit_message_text( textf{poll[question]}\n\n当前结果\n{results} ) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加投票命令 updater.dispatcher.add_handler(CommandHandler(poll, start_poll)) # 添加按钮回调 updater.dispatcher.add_handler(CallbackQueryHandler(button_callback)) # ...其他代码4.2 个性化用户交互通过记忆用户偏好和交互历史你可以打造更个性化的机器人体验user_preferences {} def set_preference(update: Update, context: CallbackContext) - None: if len(context.args) 2: update.message.reply_text(使用方法/setpref 偏好名 值) return user_id update.message.from_user.id pref_name context.args[0] pref_value .join(context.args[1:]) if user_id not in user_preferences: user_preferences[user_id] {} user_preferences[user_id][pref_name] pref_value update.message.reply_text(f已设置 {pref_name} 为 {pref_value}) def get_preference(update: Update, context: CallbackContext) - None: if not context.args: update.message.reply_text(使用方法/getpref 偏好名) return user_id update.message.from_user.id pref_name context.args[0] if user_id in user_preferences and pref_name in user_preferences[user_id]: update.message.reply_text( f{pref_name}: {user_preferences[user_id][pref_name]} ) else: update.message.reply_text(未找到该偏好设置) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加偏好设置命令 updater.dispatcher.add_handler(CommandHandler(setpref, set_preference)) updater.dispatcher.add_handler(CommandHandler(getpref, get_preference)) # ...其他代码4.3 与外部服务集成将机器人与其他流行服务集成可以大幅扩展其功能。例如与GitHub集成实现issue跟踪def github_issue(update: Update, context: CallbackContext) - None: if len(context.args) 2: update.message.reply_text(使用方法/issue 仓库名 问题标题 问题描述) return repo context.args[0] title context.args[1] body .join(context.args[2:]) if len(context.args) 2 else # 这里应该是实际调用GitHub API创建issue的代码 # 需要GitHub个人访问令牌 update.message.reply_text(f已在 {repo} 创建issue: {title}) def main(): updater Updater(YOUR_BOT_TOKEN) # 添加GitHub issue命令 updater.dispatcher.add_handler(CommandHandler(issue, github_issue)) # ...其他代码在实际项目中我发现最实用的机器人功能往往是那些解决特定小痛点的功能而不是试图做所有事情的全能型机器人。比如一个专门用来快速转换时区的机器人或者一个能根据食谱名称返回配料清单的机器人在实际使用中会比功能复杂但不精专的机器人更有价值。
