From 2facef7509b5cee2f60a4671402665815f6fcca7 Mon Sep 17 00:00:00 2001 From: home-dev-pookz Date: Sat, 12 Apr 2025 18:42:21 +0800 Subject: [PATCH] =?UTF-8?q?add=20=E7=99=BE=E5=AE=B6=E8=99=9F=E4=B8=8A?= =?UTF-8?q?=E5=82=B3=E5=AF=A6=E7=8F=BE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.MD | 3 +- examples/get_baijiahao_cookie.py | 10 + examples/get_douyin_cookie.py | 1 + examples/get_kuaishou_cookie.py | 1 + examples/get_tencent_cookie.py | 1 + examples/get_tk_cookie.py | 1 + examples/upload_video_to_baijiahao.py | 27 +++ uploader/baijiahao_uploader/__init__.py | 0 uploader/baijiahao_uploader/main.py | 248 ++++++++++++++++++++++++ utils/log.py | 1 + utils/network.py | 28 +++ 11 files changed, 320 insertions(+), 1 deletion(-) create mode 100644 examples/get_baijiahao_cookie.py create mode 100644 examples/upload_video_to_baijiahao.py create mode 100644 uploader/baijiahao_uploader/__init__.py create mode 100644 uploader/baijiahao_uploader/main.py create mode 100644 utils/network.py diff --git a/README.MD b/README.MD index b3e278e..c0e1dae 100644 --- a/README.MD +++ b/README.MD @@ -10,7 +10,8 @@ social-auto-upload 该项目旨在自动化发布视频到各个社交媒体平 - [x] bilibili - [x] 小红书 - [x] 快手 - - [ ] 百家号 + - [x] 百家号 + - [ ] qq視頻 - 部分国外社交媒体： - [x] tiktok diff --git a/examples/get_baijiahao_cookie.py b/examples/get_baijiahao_cookie.py new file mode 100644 index 0000000..418a78b --- /dev/null +++ b/examples/get_baijiahao_cookie.py @@ -0,0 +1,10 @@ +import asyncio +from pathlib import Path + +from conf import BASE_DIR +from uploader.baijiahao_uploader.main import baijiahao_setup + +if __name__ == '__main__': + account_file = Path(BASE_DIR / "cookies" / "baijiahao_uploader" / "account.json") + account_file.parent.mkdir(exist_ok=True) + cookie_setup = asyncio.run(baijiahao_setup(str(account_file), handle=True)) diff --git a/examples/get_douyin_cookie.py b/examples/get_douyin_cookie.py index aa181d9..cc8a433 100644 --- a/examples/get_douyin_cookie.py +++ b/examples/get_douyin_cookie.py @@ -6,4 +6,5 @@ from uploader.douyin_uploader.main import douyin_setup if __name__ == '__main__': account_file = Path(BASE_DIR / "cookies" / "douyin_uploader" / "account.json") + account_file.parent.mkdir(exist_ok=True) cookie_setup = asyncio.run(douyin_setup(str(account_file), handle=True)) diff --git a/examples/get_kuaishou_cookie.py b/examples/get_kuaishou_cookie.py index 17740ed..9301ae4 100644 --- a/examples/get_kuaishou_cookie.py +++ b/examples/get_kuaishou_cookie.py @@ -6,4 +6,5 @@ from uploader.ks_uploader.main import ks_setup if __name__ == '__main__': account_file = Path(BASE_DIR / "cookies" / "ks_uploader" / "account.json") + account_file.parent.mkdir(exist_ok=True) cookie_setup = asyncio.run(ks_setup(str(account_file), handle=True)) diff --git a/examples/get_tencent_cookie.py b/examples/get_tencent_cookie.py index 178dddb..06361c4 100644 --- a/examples/get_tencent_cookie.py +++ b/examples/get_tencent_cookie.py @@ -6,4 +6,5 @@ from uploader.tencent_uploader.main import weixin_setup if __name__ == '__main__': account_file = Path(BASE_DIR / "cookies" / "tencent_uploader" / "account.json") + account_file.parent.mkdir(exist_ok=True) cookie_setup = asyncio.run(weixin_setup(str(account_file), handle=True)) diff --git a/examples/get_tk_cookie.py b/examples/get_tk_cookie.py index 2b2ce31..1f33fea 100644 --- a/examples/get_tk_cookie.py +++ b/examples/get_tk_cookie.py @@ -6,4 +6,5 @@ from uploader.tk_uploader.main_chrome import tiktok_setup if __name__ == '__main__': account_file = Path(BASE_DIR / "cookies" / "tk_uploader" / "account.json") + account_file.parent.mkdir(exist_ok=True) cookie_setup = asyncio.run(tiktok_setup(str(account_file), handle=True)) diff --git a/examples/upload_video_to_baijiahao.py b/examples/upload_video_to_baijiahao.py new file mode 100644 index 0000000..fa3f487 --- /dev/null +++ b/examples/upload_video_to_baijiahao.py @@ -0,0 +1,27 @@ +import asyncio +from pathlib import Path + +from conf import BASE_DIR +from uploader.baijiahao_uploader.main import baijiahao_setup, BaiJiaHaoVideo +from utils.files_times import generate_schedule_time_next_day, get_title_and_hashtags + + +if __name__ == '__main__': + filepath = Path(BASE_DIR) / "videos" + account_file = Path(BASE_DIR / "cookies" / "baijiahao_uploader" / "account.json") + # 获取视频目录 + folder_path = Path(filepath) + # 获取文件夹中的所有文件 + files = list(folder_path.glob("*.mp4")) + file_num = len(files) + publish_datetimes = generate_schedule_time_next_day(file_num, 1, daily_times=[16]) + cookie_setup = asyncio.run(baijiahao_setup(account_file, handle=False)) + for index, file in enumerate(files): + title, tags = get_title_and_hashtags(str(file)) + thumbnail_path = file.with_suffix('.png') + # 打印视频文件名、标题和 hashtag + print(f"视频文件名：{file}") + print(f"标题：{title}") + print(f"Hashtag：{tags}") + app = BaiJiaHaoVideo(title, file, tags, publish_datetimes[index], account_file) + asyncio.run(app.main(), debug=False) diff --git a/uploader/baijiahao_uploader/__init__.py b/uploader/baijiahao_uploader/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/uploader/baijiahao_uploader/main.py b/uploader/baijiahao_uploader/main.py new file mode 100644 index 0000000..c6f1fc0 --- /dev/null +++ b/uploader/baijiahao_uploader/main.py @@ -0,0 +1,248 @@ +# -*- coding: utf-8 -*- +import random +from datetime import datetime + +from playwright.async_api import Playwright, async_playwright, Page +import os +import asyncio + +from conf import LOCAL_CHROME_PATH +from utils.base_social_media import set_init_script +from utils.log import baijiahao_logger +from utils.network import async_retry + + +async def baijiahao_cookie_gen(account_file): + async with async_playwright() as playwright: + options = { + 'args': [ + '--lang en-GB' + ], + 'headless': False, # Set headless option here + } + # Make sure to run headed. + browser = await playwright.chromium.launch(**options) + # Setup context however you like. + context = await browser.new_context() # Pass any options + context = await set_init_script(context) + # Pause the page, and start recording manually. + page = await context.new_page() + await page.goto("https://baijiahao.baidu.com/builder/theme/bjh/login") + await page.pause() + # 点击调试器的继续，保存cookie + await context.storage_state(path=account_file) + baijiahao_logger.success("cookie saved") + + +async def cookie_auth(account_file): + async with async_playwright() as playwright: + browser = await playwright.chromium.launch(headless=True) + context = await browser.new_context(storage_state=account_file) + context = await set_init_script(context) + # 创建一个新的页面 + page = await context.new_page() + # 访问指定的 URL + await page.goto("https://baijiahao.baidu.com/builder/rc/home") + await page.wait_for_timeout(timeout=5000) + + if await page.get_by_text('注册/登录百家号').count(): + baijiahao_logger.error("等待5秒 cookie 失效") + return False + else: + baijiahao_logger.success("[+] cookie 有效") + return True + + +async def baijiahao_setup(account_file, handle=False): + if not os.path.exists(account_file) or not await cookie_auth(account_file): + if not handle: + return False + baijiahao_logger.error("cookie文件不存在或已失效，即将自动打开浏览器，请扫码登录，登陆后会自动生成cookie文件") + await baijiahao_cookie_gen(account_file) + return True + +class BaiJiaHaoVideo(object): + def __init__(self, title, file_path, tags, publish_date: datetime, account_file, proxy_setting=None): + self.title = title # 视频标题 + self.file_path = file_path + self.tags = tags + self.publish_date = publish_date + self.account_file = account_file + self.date_format = '%Y年%m月%d日 %H:%M' + self.local_executable_path = LOCAL_CHROME_PATH + self.proxy_setting = proxy_setting + + async def set_schedule_time(self, page, publish_date): + """ + todo 时间选择，日后在处理 百家号的时间选择不准确，目前是随机 + """ + publish_date_day = f"{publish_date.month}月{publish_date.day}日" if publish_date.day >9 else f"{publish_date.month}月0{publish_date.day}日" + publish_date_hour = f"{publish_date.hour}点" + publish_date_min = f"{publish_date.minute}分" + await page.wait_for_selector('div.select-wrap', timeout=5000) + for _ in range(3): + try: + await page.locator('div.select-wrap').nth(0).click() + await page.wait_for_selector('div.rc-virtual-list div.cheetah-select-item', timeout=5000) + break + except: + await page.locator('div.select-wrap').nth(0).click() + # page.locator(f'div.rc-virtual-list-holder-inner >> text={publish_date_day}').click() + await page.wait_for_timeout(2000) + await page.locator(f'div.rc-virtual-list div.cheetah-select-item >> text={publish_date_day}').click() + await page.wait_for_timeout(2000) + + # 改为随机点击一个 hour + for _ in range(3): + try: + await page.locator('div.select-wrap').nth(1).click() + await page.wait_for_selector('div.rc-virtual-list div.rc-virtual-list-holder-inner:visible', timeout=5000) + break + except: + await page.locator('div.select-wrap').nth(1).click() + await page.wait_for_timeout(2000) + current_choice_hour = await page.locator('div.rc-virtual-list:visible div.cheetah-select-item-option').count() + await page.wait_for_timeout(2000) + await page.locator('div.rc-virtual-list:visible div.cheetah-select-item-option').nth( + random.randint(1, current_choice_hour-3)).click() + # 2024.08.05 current_choice_hour的获取可能有问题，页面有7，这里获取了10，暂时硬编码至6 + + await page.wait_for_timeout(2000) + await page.locator("button >> text=定时发布").click() + + + async def handle_upload_error(self, page): + # 日后实现，目前没遇到 + return + print("视频出错了，重新上传中") + + async def upload(self, playwright: Playwright) -> None: + # 使用 Chromium 浏览器启动一个浏览器实例 + browser = await playwright.chromium.launch(headless=False, executable_path=self.local_executable_path, proxy=self.proxy_setting) + # 创建一个浏览器上下文，使用指定的 cookie 文件 + context = await browser.new_context(storage_state=f"{self.account_file}", user_agent='Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/127.0.4324.150 Safari/537.36') + # context = await set_init_script(context) + await context.grant_permissions(['geolocation']) + + # 创建一个新的页面 + page = await context.new_page() + # 访问指定的 URL + await page.goto("https://baijiahao.baidu.com/builder/rc/edit?type=videoV2", timeout=60000) + baijiahao_logger.info(f"正在上传-------{self.title}.mp4") + # 等待页面跳转到指定的 URL，没进入，则自动等待到超时 + baijiahao_logger.info('正在打开主页...') + await page.wait_for_url("https://baijiahao.baidu.com/builder/rc/edit?type=videoV2", timeout=60000) + + # 点击 "上传视频" 按钮 + await page.locator("div[class^='video-main-container'] input").set_input_files(self.file_path) + + # 等待页面跳转到指定的 URL + while True: + # 判断是是否进入视频发布页面，没进入，则自动等待到超时 + try: + await page.wait_for_selector("div#formMain:visible") + break + except: + baijiahao_logger.info("正在等待进入视频发布页面...") + await asyncio.sleep(0.1) + + # 填充标题和话题 + # 这里为了避免页面变化，故使用相对位置定位：作品标题父级右侧第一个元素的input子元素 + await asyncio.sleep(1) + baijiahao_logger.info("正在填充标题和话题...") + await self.add_title_tags(page) + + upload_status = await self.uploading_video(page) + if not upload_status: + baijiahao_logger.error(f"发现上传出错了... 文件:{self.file_path}") + raise + + # 判断视频封面图是否生成成功 + while True: + baijiahao_logger.info("正在确认封面完成, 准备去点击定时/发布...") + if await page.locator("div.cheetah-spin-container img").count(): + baijiahao_logger.info("封面已完成，点击定时/发布...") + break + else: + baijiahao_logger.info("等待封面生成...") + await asyncio.sleep(3) + + await self.publish_video(page, self.publish_date) + await page.wait_for_timeout(2000) + if await page.locator('div.passMod_dialog-container >> text=百度安全验证:visible').count(): + baijiahao_logger.error("出现验证，退出") + raise Exception("出现验证，退出") + await page.wait_for_url("https://baijiahao.baidu.com/builder/rc/clue**", timeout=5000) + baijiahao_logger.success("视频发布成功") + + await context.storage_state(path=self.account_file) # 保存cookie + baijiahao_logger.info('cookie更新完毕！') + await asyncio.sleep(2) # 这里延迟是为了方便眼睛直观的观看 + # 关闭浏览器上下文和浏览器实例 + await context.close() + await browser.close() + + + @async_retry(timeout=300) # 例如，最多重试3次，超时时间为180秒 + async def uploading_video(self, page): + while True: + upload_failed = await page.locator('div .cover-overlay:has-text("上传失败")').count() + if upload_failed: + baijiahao_logger.error("发现上传出错了...") + # await self.handle_upload_error(page) # 假设这是处理上传错误的函数 + return False + + uploading = await page.locator('div .cover-overlay:has-text("上传中")').count() + if uploading: + baijiahao_logger.info("正在上传视频中...") + await asyncio.sleep(2) # 等待2秒再次检查 + continue + + # 检查上传是否成功 + if not uploading and not upload_failed: + baijiahao_logger.success("视频上传完毕") + return True + + async def set_schedule_publish(self, page, publish_date): + while True: + schedule_element = page.locator("div.op-btn-outter-content >> text=定时发布").locator("..").locator( + 'button') + try: + await schedule_element.click() + await page.wait_for_selector('div.select-wrap:visible', timeout=3000) + await page.wait_for_timeout(timeout=2000) + baijiahao_logger.info("开始点击发布定时...") + await self.set_schedule_time(page, publish_date) + break + except Exception as e: + baijiahao_logger.error(f"定时发布失败: {e}") + raise # 重新抛出异常，让重试装饰器捕获 + + @async_retry(timeout=300) # 例如，最多重试3次，超时时间为180秒 + async def publish_video(self, page: Page, publish_date): + if publish_date != 0: + # 定时发布 + await self.set_schedule_publish(page, publish_date) + else: + # 立即发布 + await self.direct_publish(page) + + async def direct_publish(self, page): + try: + publish_button = page.locator("button >> text=发布") + if await publish_button.count(): + await publish_button.click() + except Exception as e: + baijiahao_logger.error(f"直接发布视频失败: {e}") + raise # 重新抛出异常，让重试装饰器捕获 + + async def add_title_tags(self, page): + title_container = page.get_by_placeholder('添加标题获得更多推荐') + if len(self.title) <= 8: + self.title += " 你不知道的" + await title_container.fill(self.title[:30]) + + async def main(self): + async with async_playwright() as playwright: + await self.upload(playwright) + diff --git a/utils/log.py b/utils/log.py index fa63a8c..e8b8354 100644 --- a/utils/log.py +++ b/utils/log.py @@ -49,3 +49,4 @@ xhs_logger = create_logger('xhs', 'logs/xhs.log') tiktok_logger = create_logger('tiktok', 'logs/tiktok.log') bilibili_logger = create_logger('bilibili', 'logs/bilibili.log') kuaishou_logger = create_logger('kuaishou', 'logs/kuaishou.log') +baijiahao_logger = create_logger('baijiahao', 'logs/baijiahao.log') diff --git a/utils/network.py b/utils/network.py new file mode 100644 index 0000000..dab5a2c --- /dev/null +++ b/utils/network.py @@ -0,0 +1,28 @@ +import asyncio +import time +from functools import wraps + + +def async_retry(timeout=60, max_retries=None): + def decorator(func): + @wraps(func) + async def wrapper(*args, **kwargs): + start_time = time.time() + attempts = 0 + while True: + try: + return await func(*args, **kwargs) + except Exception as e: + attempts += 1 + if max_retries is not None and attempts >= max_retries: + print(f"Reached maximum retries of {max_retries}.") + raise Exception(f"Failed after {max_retries} retries.") from e + if time.time() - start_time > timeout: + print(f"Function timeout after {timeout} seconds.") + raise TimeoutError(f"Function execution exceeded {timeout} seconds timeout.") from e + print(f"Attempt {attempts} failed: {e}. Retrying...") + await asyncio.sleep(1) # Sleep to avoid tight loop or provide backoff logic here + + return wrapper + + return decorator \ No newline at end of file