Develop

.gitignore

@@ -36,4 +36,4 @@ nosetests.xml
 .mr.developer.cfg
 .project
 .pydevproject
-.idea
+config.json

Dockerfile

@@ -1,4 +1,4 @@
-FROM python:3.6
+FROM python:3.7
 MAINTAINER binux <roy@binux.me>
 
 # install phantomjs
@@ -26,6 +26,8 @@ RUN pip install -r /opt/pyspider/requirements.txt
 
 # add all repo
 ADD ./ /opt/pyspider
+# install seadaka requ
+RUN pip install -r /opt/pyspider/requirements-seadaka.txt
 
 # run test
 WORKDIR /opt/pyspider

README.md

@@ -8,7 +8,7 @@ A Powerful Spider(Web Crawler) System in Python.
 - [MySQL](https://www.mysql.com/), [MongoDB](https://www.mongodb.org/), [Redis](http://redis.io/), [SQLite](https://www.sqlite.org/), [Elasticsearch](https://www.elastic.co/products/elasticsearch); [PostgreSQL](http://www.postgresql.org/) with [SQLAlchemy](http://www.sqlalchemy.org/) as database backend
 - [RabbitMQ](http://www.rabbitmq.com/), [Redis](http://redis.io/) and [Kombu](http://kombu.readthedocs.org/) as message queue
 - Task priority, retry, periodical, recrawl by age, etc...
-- Distributed architecture, Crawl Javascript pages, Python 2.{6,7}, 3.{3,4,5,6} support, etc...
+- Distributed architecture, Crawl Javascript pages, Python 3.{6, 7, 8, 9} support, etc...
 
 Tutorial: [http://docs.pyspider.org/en/latest/tutorial/](http://docs.pyspider.org/en/latest/tutorial/)  
 Documentation: [http://docs.pyspider.org/](http://docs.pyspider.org/)  
@@ -18,7 +18,7 @@ Sample Code
 -----------
 
 ```python
-from pyspider.libs.base_handler import *
+from pyspider.libs.base_handler import BaseHandler, config, every
 
 
 class Handler(BaseHandler):
@@ -66,6 +66,12 @@ TODO
 
 ### v0.4.0
 
+- [ ] 适配 python 3.9， 放弃 3.6 以下版本, try my best to fix bug
+- [ ] fix travis and Coverage 
+- [ ] review docker
+
+### v0.5.0
+
 - [ ] a visual scraping interface like [portia](https://github.com/scrapinghub/portia)
 
 

docker-compose.yaml

@@ -1,4 +1,4 @@
-version: "3.7"
+version: "3.3"
 
 # replace /path/to/dir/ to point to config.json
 

docs/conf.py

@@ -1,24 +1,25 @@
 #!/usr/bin/env python
-# -*- encoding: utf-8 -*-
 # vim: set et sw=4 ts=4 sts=4 ff=unix fenc=utf8:
 # Author: Binux<roy@binux.me>
 #         http://binux.me
 # Created on 2015-11-10 01:31:54
 
 import sys
 from unittest.mock import MagicMock
+
 from recommonmark.parser import CommonMarkParser
 
+
 class Mock(MagicMock):
     @classmethod
     def __getattr__(cls, name):
-            return Mock()
+        return Mock()
 
 MOCK_MODULES = ['pycurl', 'lxml', 'psycopg2']
 sys.modules.update((mod_name, Mock()) for mod_name in MOCK_MODULES)
 
 source_parsers = {
-        '.md': CommonMarkParser,
+    '.md': CommonMarkParser,
 }
 
 source_suffix = ['.rst', '.md']

pyspider/__init__.py

@@ -1,5 +1,4 @@
 #!/usr/bin/env python
-# -*- encoding: utf-8 -*-
 # vim: set et sw=4 ts=4 sts=4 ff=unix fenc=utf8:
 # Author: Binux<i@binux.me>
 #         http://binux.me

pyspider/database/__init__.py

@@ -1,12 +1,14 @@
 #!/usr/bin/env python
-# -*- encoding: utf-8 -*-
 # vim: set et sw=4 ts=4 sts=4 ff=unix fenc=utf8:
 # Author: Binux<i@binux.me>
 #         http://binux.me
 # Created on 2014-10-08 15:04:08
 
-import os, requests, json
-from six.moves.urllib.parse import urlparse, parse_qs
+import json
+import os
+
+import requests
+from six.moves.urllib.parse import parse_qs, urlparse
 
 
 def connect_database(url):
@@ -60,16 +62,15 @@ def _connect_database(url):  # NOQA
         other_scheme = "+".join(scheme[1:-1])
 
     if dbtype not in ('taskdb', 'projectdb', 'resultdb'):
-        raise LookupError('unknown database type: %s, '
-                          'type should be one of ["taskdb", "projectdb", "resultdb"]', dbtype)
+        raise LookupError(f'unknown database type: {dbtype}, type should be one of ["taskdb", "projectdb", "resultdb"]')
 
     if engine == 'mysql':
-        return _connect_mysql(parsed,dbtype)
+        return _connect_mysql(parsed, dbtype)
 
     elif engine == 'sqlite':
-        return _connect_sqlite(parsed,dbtype)
+        return _connect_sqlite(parsed, dbtype)
     elif engine == 'mongodb':
-        return _connect_mongodb(parsed,dbtype,url)
+        return _connect_mongodb(parsed, dbtype, url)
 
     elif engine == 'sqlalchemy':
         return _connect_sqlalchemy(parsed, dbtype, url, other_scheme)
@@ -88,44 +89,44 @@ def _connect_database(url):  # NOQA
             from .local.projectdb import ProjectDB
             return ProjectDB(scripts)
         else:
-            raise LookupError('not supported dbtype: %s', dbtype)
+            raise LookupError(f'not supported dbtype: {dbtype}')
     elif engine == 'elasticsearch' or engine == 'es':
         return _connect_elasticsearch(parsed, dbtype)
 
     elif engine == 'couchdb':
         return _connect_couchdb(parsed, dbtype, url)
 
     else:
-        raise Exception('unknown engine: %s' % engine)
+        raise Exception(f'unknown engine: {engine}')
 
 
-def _connect_mysql(parsed,dbtype):
-    parames = {}
+def _connect_mysql(parsed, dbtype):
+    params = dict()
     if parsed.username:
-        parames['user'] = parsed.username
+        params['user'] = parsed.username
     if parsed.password:
-        parames['passwd'] = parsed.password
+        params['passwd'] = parsed.password
     if parsed.hostname:
-        parames['host'] = parsed.hostname
+        params['host'] = parsed.hostname
     if parsed.port:
-        parames['port'] = parsed.port
+        params['port'] = parsed.port
     if parsed.path.strip('/'):
-        parames['database'] = parsed.path.strip('/')
+        params['database'] = parsed.path.strip('/')
 
     if dbtype == 'taskdb':
         from .mysql.taskdb import TaskDB
-        return TaskDB(**parames)
+        return TaskDB(**params)
     elif dbtype == 'projectdb':
         from .mysql.projectdb import ProjectDB
-        return ProjectDB(**parames)
+        return ProjectDB(**params)
     elif dbtype == 'resultdb':
         from .mysql.resultdb import ResultDB
-        return ResultDB(**parames)
+        return ResultDB(**params)
     else:
         raise LookupError
 
 
-def _connect_sqlite(parsed,dbtype):
+def _connect_sqlite(parsed, dbtype):
     if parsed.path.startswith('//'):
         path = '/' + parsed.path.strip('/')
     elif parsed.path.startswith('/'):
@@ -148,7 +149,7 @@ def _connect_sqlite(parsed,dbtype):
         raise LookupError
 
 
-def _connect_mongodb(parsed,dbtype,url):
+def _connect_mongodb(parsed, dbtype, url):
     url = url.replace(parsed.scheme, 'mongodb')
     parames = {}
     if parsed.path.strip('/'):
@@ -167,7 +168,7 @@ def _connect_mongodb(parsed,dbtype,url):
         raise LookupError
 
 
-def _connect_sqlalchemy(parsed, dbtype,url, other_scheme):
+def _connect_sqlalchemy(parsed, dbtype, url, other_scheme):
     if not other_scheme:
         raise Exception('wrong scheme format: %s' % parsed.scheme)
     url = url.replace(parsed.scheme, other_scheme)

pyspider/database/base/projectdb.py

@@ -1,14 +1,15 @@
 #!/usr/bin/env python
-# -*- encoding: utf-8 -*-
 # vim: set et sw=4 ts=4 sts=4 ff=unix fenc=utf8:
 # Author: Binux<i@binux.me>
 #         http://binux.me
 # Created on 2014-02-09 11:28:52
 
 import re
+from typing import Dict
 
 # NOTE: When get/get_all/check_update from database with default fields,
 #       all following fields should be included in output dict.
+
 {
     'project': {
         'name': str,
@@ -34,10 +35,10 @@ class ProjectDB(object):
         'RUNNING',
     ]
 
-    def insert(self, name, obj={}):
+    def insert(self, name, obj: Dict = None):
         raise NotImplementedError
 
-    def update(self, name, obj={}, **kwargs):
+    def update(self, name, obj: Dict = None, **kwargs):
         raise NotImplementedError
 
     def get_all(self, fields=None):
@@ -54,9 +55,9 @@ def check_update(self, timestamp, fields=None):
 
     def split_group(self, group, lower=True):
         if lower:
-            return re.split("\W+", (group or '').lower())
+            return re.split(r"\W+", (group or '').lower())
         else:
-            return re.split("\W+", group or '')
+            return re.split(r"\W+", group or '')
 
     def verify_project_name(self, name):
         if len(name) > 64:

pyspider/database/base/resultdb.py

@@ -1,5 +1,4 @@
 #!/usr/bin/env python
-# -*- encoding: utf-8 -*-
 # vim: set et sw=4 ts=4 sts=4 ff=unix fenc=utf8:
 # Author: Binux<i@binux.me>
 #         http://binux.me

pyspider/database/base/taskdb.py

@@ -1,5 +1,4 @@
 #!/usr/bin/env python
-# -*- encoding: utf-8 -*-
 # vim: set et sw=4 ts=4 sts=4 ff=unix fenc=utf8:
 # Author: Binux<i@binux.me>
 #         http://binux.me
@@ -76,10 +75,14 @@ def status_count(self, project):
         '''
         raise NotImplementedError
 
-    def insert(self, project, taskid, obj={}):
+    def insert(self, project, taskid, obj: dict = None):
+        if obj is None:
+            obj = dict()
         raise NotImplementedError
 
-    def update(self, project, taskid, obj={}, **kwargs):
+    def update(self, project, taskid, obj: dict = None, **kwargs):
+        if obj is None:
+            obj = dict()
         raise NotImplementedError
 
     def drop(self, project):