增加代理服务

src/app/main.py

@@ -66,7 +66,7 @@ class AppEnvType:
     DEFAULT_STATS_CHECK_INTERVAL = 10  # IP 数据统计间隔
 
     DEFAULT_REQUEST_TIME_OUT = 5
-    DEFAULT_REQUEST_CHECK_TIME_OUT = 3
+    DEFAULT_REQUEST_CHECK_TIME_OUT = 5
 
     # Rate
     RE_PUSH_TO_CHECK_POOL_RATE = 0.6  # 如果 总 IP 数量 > IP 池数量 * Rate  则跳过本次推送任务

src/sites/github_proxy_list.py

@@ -0,0 +1,34 @@
+from src.app.ip_get import IPGet, SiteResponse
+from src.lib.structs import SiteData, SiteResponseData
+
+key = 'github_proxy_list'
+
+
+@IPGet.config(key)
+def config():
+    site = SiteData()
+    site.name = 'Github proxy list'
+    site.pages = ['https://raw.githubusercontent.com/clarketm/proxy-list/master/proxy-list-raw.txt']
+    return site
+
+
+@IPGet.parse(key)
+def parse(resp: SiteResponse):
+    import re
+    ips = re.findall(r'(?:\d{1,3}\.){3}\d{1,3}:\d+', resp.text)
+    for ip in ips:
+        try:
+            item = ip.split(':')
+            res = SiteResponseData()
+            res.ip = item[0]
+            res.port = item[1]
+            yield res
+        except Exception:
+            continue
+
+
+if __name__ == '__main__':
+    from src.lib.func import run_until_complete
+
+    runner = IPGet.test_crawl(key)
+    run_until_complete(runner)

src/sites/proxy_daily.py

@@ -0,0 +1,34 @@
+from src.app.ip_get import IPGet, SiteResponse
+from src.lib.structs import SiteData, SiteResponseData
+
+key = 'proxy_daily'
+
+
+@IPGet.config(key)
+def config():
+    site = SiteData()
+    site.name = 'Proxy daily'
+    site.pages = ['https://proxy-daily.com/']
+    return site
+
+
+@IPGet.parse(key)
+def parse(resp: SiteResponse):
+    import re
+    ips = re.findall(r'(?:\d{1,3}\.){3}\d{1,3}:\d+', resp.text)
+    for ip in ips:
+        try:
+            item = ip.split(':')
+            res = SiteResponseData()
+            res.ip = item[0]
+            res.port = item[1]
+            yield res
+        except Exception:
+            continue
+
+
+if __name__ == '__main__':
+    from src.lib.func import run_until_complete
+
+    runner = IPGet.test_crawl(key)
+    run_until_complete(runner)

src/sites/spys_me.py

@@ -0,0 +1,34 @@
+from src.app.ip_get import IPGet, SiteResponse
+from src.lib.structs import SiteData, SiteResponseData
+
+key = 'spysme'
+
+
+@IPGet.config(key)
+def config():
+    site = SiteData()
+    site.name = 'Spys.me'
+    site.pages = ['http://spys.me/proxy.txt']
+    return site
+
+
+@IPGet.parse(key)
+def parse(resp: SiteResponse):
+    import re
+    ips = re.findall(r'(?:\d{1,3}\.){3}\d{1,3}:\d+', resp.text)
+    for ip in ips:
+        try:
+            item = ip.split(':')
+            res = SiteResponseData()
+            res.ip = item[0]
+            res.port = item[1]
+            yield res
+        except Exception:
+            continue
+
+
+if __name__ == '__main__':
+    from src.lib.func import run_until_complete
+
+    runner = IPGet.test_crawl(key)
+    run_until_complete(runner)