TG 频道/群组文件批量下载 无视分享限制

前两行为依赖 42-53为配置注意修改,55-56是使用代理的配置 ,58-59是不用代理的配置,按照需求注释

# pip install cryptg
# pip install pyrogram
import json
import os
import shutil
import time
# import File_move
import sys

from pyrogram import Client, filters

# 导入logging模块
import logging

# 创建一个loggger,并设置日志级别
logger = logging.getLogger()
# logger 存储到文件
logger.setLevel(logging.DEBUG)

# 创建一个handler,用于将日志输出到控制台,并设置日志级别
ch = logging.StreamHandler()
ch.setLevel(logging.INFO)

# 创建一个handler,用于将日志输出到文件,并设置日志级别
fh = logging.FileHandler('log.txt', encoding='utf-8')
fh.setLevel(logging.ERROR)

# 创建一个handler,用于将日志输出到文件,并设置日志级别
fh_all = logging.FileHandler('log_all.txt', encoding='utf-8')
fh_all.setLevel(logging.INFO)

# 定义handler的输出格式
formatter = logging.Formatter(
    '%(asctime)s-%(name)s-%(filename)s-[line:%(lineno)d]''-%(levelname)s-[日志信息]: %(message)s')
ch.setFormatter(formatter)

# 给logger添加handler
logger.addHandler(ch)
logger.addHandler(fh)
logger.addHandler(fh_all)

api_id = 11
api_hash = '11'  # https://my.telegram.org/auth   登陆获取
phone_number = '11111'  # 手机号
chat_id = 1111  # 群组id
proxy = {
    "scheme": "socks5",
    "hostname": "127.0.0.1",
    "port": 6153
}


download_file = '/root/download/download_file'  # 下载地址

# app = Client("my_account", api_id, api_hash, proxy=proxy, phone_number=phone_number, device_model='PC',
#              system_version='Linux', max_concurrent_transmissions=16)

app = Client("my_account", api_id, api_hash, phone_number=phone_number, device_model='PC',
             system_version='Linux', max_concurrent_transmissions=32)


async def progress(current, total):
    print(f"当前已下载:{current * 100 / total:.1f}%")


async def main1():
    await app.start()
    all_msg_num = await app.get_chat_history_count(chat_id)
    logger.info("当前群组消息总数为:" + str(all_msg_num))
    number = 0
    # for i in range(all_msg_num, 0, -1):
    for i in range(all_msg_num, 0, -1):
        # 输出当前时间
        logger.info("当前时间:" + time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()))
        message = await app.get_messages(chat_id, i)
        logger.info("目前第{}条信息".format(message.id))
        if message.photo:
            if message.photo.file_id:
                filename = message.photo.file_id + '.jpg'
                final_filename = download_file + '/' + filename
                if os.path.exists(final_filename):
                    logger.info("文件存在")
                    continue
                else:
                    logger.info("开始下载")
                    logger.info("消息ID :{}".format(message.id))
                    await app.download_media(message, file_name=final_filename, progress=progress)
        if message.video:
            if message.video.file_id:
                filename = message.video.file_id + '.mp4'
                final_filename = download_file + '/video/' + filename
                if os.path.exists(final_filename):
                    logger.info("文件存在")
                    continue
                else:
                    logger.info("开始下载")
                    logger.info("消息ID:{}".format(message.id))
                    await app.download_media(message, file_name=final_filename, progress=progress)

    number += 1
    # starr_msg 存入到numbers.txt,覆盖原来的内容
    with open('numbers.txt', 'w') as f:
        f.write(str(message.id))  # 消息id
        f.write('\n')
        f.write(str(number))  # 下载文件数量
        # if message.caption:
        #     f.write('消息标签:\n')
        #     f.write(str(message.caption[message.caption.find('#') + 6:message.caption.find('\n')]))
        logger.info("已经下载了{}个文件".format(number))
        f.close()


if __name__ == '__main__':
    app.run(main1())

给TA打赏
共{{data.count}}人
人已打赏
实用工具

aliyundrive-webdav 又一个阿里云盘webdav服务

2021-10-5 15:00:38

cj

多功能VestaCP全家桶套件一键安装脚本,文件管理器已破解

2020-1-19 3:57:10

0 条回复 A文章作者 M管理员
    暂无讨论,说说你的看法吧
个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索