Celery-based web crawler admin platform for managing distributed web spiders regardless of languages and frameworks.
- Python3
- MongoDB
- Redis
# install the requirements for backend
pip install -r requirements.txt
# install frontend node modules
cd frontend
npm install
Please edit configuration file config.py
to configure api and database connections.
# Start backend API
python app.py
# Start Flower service
python ./bin/run_flower.py
# Start worker
python ./bin/run_worker.py
# run frontend client
cd frontend
npm run serve
Crawlab's architecture is very similar to Celery's, but a few more modules including Frontend, Spiders and Flower are added to feature the crawling management functionality.
Nodes are actually the workers defined in Celery. A node is running and connected to a task queue, redis for example, to receive and run tasks. As spiders need to be deployed to the nodes, users should specify their ip addresses and ports before the deployment.
In config.py
file, edit PROJECT_SOURCE_FILE_FOLDER
as the directory where the spiders projects are located. The web app will discover spider projects automatically. How simple is that!
All spiders need to be deployed to a specific node before crawling. Simply click "Deploy" button on spider detail page and the spiders will be deployed to all active nodes.
After deploying the spider, you can click "Run" button on spider detail page and select a specific node to start crawling. It will triggers a task for the crawling, where you can see in detail in tasks page.
Tasks are triggered and run by the workers. Users can view the task status, logs and results in the task detail page.
This is a Flask app that provides necessary API for common operations such as CRUD, spider deployment and task running. Each node has to run the flask app to get spiders deployed on this machine. Simply run python manage.py app
or python ./bin/run_app.py
to start the app.
Broker is the same as defined in Celery. It is the queue for running async tasks.
Frontend is basically a Vue SPA that inherits from Vue-Element-Admin of PanJiaChen. Thanks for his awesome template.
A task is triggered via Popen
in python subprocess
module. A Task ID is will be defined as a variable CRAWLAB_TASK_ID
in the shell environment to link the data to the task.
In your spider program, you should store the CRAWLAB_TASK_ID
value in the database with key task_id
. Then Crawlab would know how to link those results to a particular task. For now, Crawlab only supports MongoDB.
Below is an example to integrate Crawlab with Scrapy in pipelines.
import os
from pymongo import MongoClient
MONGO_HOST = '192.168.99.100'
MONGO_PORT = 27017
MONGO_DB = 'crawlab_test'
# scrapy example in the pipeline
class JuejinPipeline(object):
mongo = MongoClient(host=MONGO_HOST, port=MONGO_PORT)
db = mongo[MONGO_DB]
col_name = os.environ.get('CRAWLAB_COLLECTION')
if not col_name:
col_name = 'test'
col = db[col_name]
def process_item(self, item, spider):
item['task_id'] = os.environ.get('CRAWLAB_TASK_ID')
self.col.save(item)
return item
There are existing spider management frameworks. So why use Crawlab?
The reason is that most of the existing platforms are depending on Scrapyd, which limits the choice only within python and scrapy. Surely scrapy is a great web crawl frameowrk, but it cannot do everything.
Crawlab is easy to use, general enough to adapt spiders in any language and any framework. It has also a beautiful frontend interface for users to manage spiders much more easily.
Framework | Type | Distributed | Frontend | Scrapyd-Dependent |
---|---|---|---|---|
Crawlab | Admin Platform | Y | Y | N |
Gerapy | Admin Platform | Y | Y | Y |
SpiderKeeper | Admin Platform | Y | Y | Y |
ScrapydWeb | Admin Platform | Y | Y | Y |
Scrapyd | Web Service | Y | N | N/A |
- File Management
- MySQL Database Support
- Task Restart
- Node Monitoring
- More spider examples
- Task Stats/Analytics
- Table Filters
- Multi-Language Support (中文)
- Login & User Management
- General Search
If you like Crawlab or would like to contribute to it, please add the Author's Wechat noting "Crawlab" to enter the discussion group.