Skip to content

Commit

Permalink
add env api
Browse files Browse the repository at this point in the history
  • Loading branch information
moyada committed Mar 19, 2024
1 parent 0cc93f2 commit 5f3330d
Show file tree
Hide file tree
Showing 5 changed files with 21 additions and 15 deletions.
3 changes: 2 additions & 1 deletion browser/browser.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

from playwright.sync_api import sync_playwright, Browser, Playwright
import atexit
from core import config


# from browser import playwright
Expand Down Expand Up @@ -35,7 +36,7 @@ class PageContext:
page = None

def __init__(self, p: Playwright):
self.browser = p.chromium.launch(headless=True, args=args, timeout=20000)
self.browser = p.chromium.launch(headless=os.environ['headless'] == "1", args=args, timeout=20000)
self.context = self.browser.new_context()
self.page = self.context.new_page()

Expand Down
8 changes: 5 additions & 3 deletions browser/douyin.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
import time
import os
from playwright.sync_api import Request, Response
from browser import browser
from core import config
Expand All @@ -22,8 +23,9 @@ def get_info(cls, url: str) -> any:
except:
raise Exception('网络异常,访问分享链接失败')

for i in range(0, config.page_wait, 100):
for i in range(0, int(os.environ['page_wait']), 100):
if cls.data is not None:
timeout = False
break
p.page.wait_for_timeout(100)

Expand Down Expand Up @@ -63,7 +65,7 @@ def get_path(url) -> str:
try:
result = urllib.parse.urlparse(url).path
if result == "":
return None
return ""
return result
except ValueError:
return None
return ""
19 changes: 11 additions & 8 deletions core/apis.py
Original file line number Diff line number Diff line change
@@ -1,9 +1,8 @@
# Create your views here.
from django.http import HttpResponse, HttpResponseServerError, HttpResponseBadRequest
from django.shortcuts import redirect, render

import os
import core
from core import config
from core.model import ErrorResult
from route import controller
from core.type import Video
Expand All @@ -25,15 +24,19 @@ def set_env(request):
if not value:
v = ""
if key == "bilibili":
v = config.bilibili_cookie
if key == "page_wait":
v = config.page_wait
v = os.environ['bilibili_cookie']
elif key == "page_wait":
v = os.environ['page_wait']
elif key == "headless":
v = os.environ['headless']
return HttpResponse(v)

if key == "bilibili":
config.bilibili_cookie = value
if key == "page_wait":
config.bilibili_cookie = value
os.environ['bilibili_cookie'] = value
elif key == "page_wait":
os.environ['page_wait'] = str(int(value))
elif key == "headless":
os.environ['headless'] = value
return HttpResponse()


Expand Down
3 changes: 2 additions & 1 deletion core/config.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,4 +15,5 @@
if env_bc:
bilibili_cookie = env_bc

page_wait = 5000
os.environ['page_wait'] = "5000"
os.environ['headless'] = "1"
3 changes: 1 addition & 2 deletions service/douyin.py
Original file line number Diff line number Diff line change
Expand Up @@ -86,12 +86,11 @@ def get_info(cls, url: str) -> Result:
logger.error(f'抖音数据获取失败: {share_url}, 分享链接不支持')
return ErrorResult.VIDEO_INFO_NOT_FOUNT

if info['filter_detail'] is not None:
if 'filter_detail' in info:
msg = info['filter_detail']['notice']
logger.error(f'抖音数据获取失败: {share_url}, {msg}')
return Result.error(msg)


data = info['aweme_detail']

info = Info(platform=vtype)
Expand Down

0 comments on commit 5f3330d

Please sign in to comment.