diff --git a/src/cluster/rpa.py b/src/cluster/rpa.py index 1a5bc04..a19e39f 100644 --- a/src/cluster/rpa.py +++ b/src/cluster/rpa.py @@ -538,8 +538,8 @@ with (rpa_image.imports()): await context.add_cookies(cookies) logger.info("Loaded cookies") page: Page = await context.new_page() - # url = f"https://live.douyin.com/{webcast_id}?open_promotion_list=1&from_search=true" - url = f"https://live.douyin.com/{webcast_id}" + url = f"https://live.douyin.com/{webcast_id}?open_promotion_list=1&from_search=true" + # url = f"https://live.douyin.com/{webcast_id}" logger.info(f"Navigating to {url}") await page.goto(url, wait_until="domcontentloaded") logger.info(f"Navigating to end {url}") @@ -547,9 +547,9 @@ with (rpa_image.imports()): result.title = await page.title() logger.info(f"------Retrieved title: {result.title}") - await page.get_by_text("全部商品").click() - print("已点击 全部商品 ") - await page.wait_for_timeout(3 * 1000) + # await page.get_by_text("全部商品").click() + # print("已点击 全部商品 ") + # await page.wait_for_timeout(3 * 1000) live_status = await get_live_status_by_web_page(page, webcast_id) @@ -570,7 +570,7 @@ with (rpa_image.imports()): @retry(stop=stop_after_attempt(50), wait=wait_fixed(5)) async def wait_for_load_state_foo(page: Page, url): logger.info(f"networkidle to start {url}") - await page.wait_for_load_state(state="load") + await page.wait_for_load_state(state="networkidle") logger.info(f"networkidle to end {url}") pass @@ -582,7 +582,7 @@ with (rpa_image.imports()): # 312898731614 # webcast_ids = ["36861064178"] # webcast_ids = ["36861064178"] - webcast_id = "837842834415" + webcast_id = "65731953339" data: LiveStreamProductWatchRequest = LiveStreamProductWatchRequest(live_id=webcast_id, live_stream_name=str(ULID()))