如何使用telethon从聊天中仅获取未读消息？

pip install telethon

from telethon import TelegramClient, events
from telethon.tl.functions.messages import GetHistoryRequest
from telethon.tl.types import PeerUser, PeerChat, PeerChannel

# 你的API ID和API Hash
api_id = 'YOUR_API_ID'
api_hash = 'YOUR_API_HASH'

# 创建客户端
client = TelegramClient('session_name', api_id, api_hash)

async def get_unread_messages(chat_id):
    # 获取聊天历史
    result = await client(GetHistoryRequest(
        peer=chat_id,
        limit=100,  # 获取最近100条消息
        offset_date=None,
        offset_id=0,
        max_id=0,
        min_id=0,
        add_offset=0,
        hash=0
    ))

    # 过滤未读消息
    unread_messages = [message for message in result.messages if not message.out and message.unread]

    return unread_messages

async def main():
    # 连接到Telegram
    await client.start()

    # 替换为你要获取消息的聊天ID
    chat_id = 'CHAT_ID'

    # 获取未读消息
    unread_messages = await get_unread_messages(chat_id)

    # 打印未读消息
    for message in unread_messages:
        print(f"Message ID: {message.id}, Message: {message.message}")

    # 断开连接
    await client.disconnect()

# 运行主函数
with client:
    client.loop.run_until_complete(main())