1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
#! /usr/bin/env python
# -*- coding: utf-8 -*-
import os
import logging
from datetime import datetime
from werkzeug import generate_password_hash
from bootstrap import application, db, conf, set_logging
from flask_script import Manager
from flask_migrate import Migrate, MigrateCommand
import web.models
from web.controllers import UserController
logger = logging.getLogger('manager')
Migrate(application, db)
manager = Manager(application)
manager.add_command('db', MigrateCommand)
@manager.command
def db_empty():
"Will drop every datas stocked in db."
with application.app_context():
web.models.db_empty(db)
@manager.command
def db_create():
"Will create the database from conf parameters."
admin = {'is_admin': True, 'is_api': True, 'is_active': True,
'nickname': 'admin',
'pwdhash': generate_password_hash(
os.environ.get("ADMIN_PASSWORD", "password")),
'email': os.environ.get("ADMIN_EMAIL", "root@newspipe.localhost")}
with application.app_context():
db.create_all()
UserController(ignore_context=True).create(**admin)
@manager.command
def fetch_asyncio(user_id=None, feed_id=None):
"Crawl the feeds with asyncio."
import asyncio
with application.app_context():
from crawler import default_crawler
filters = {}
filters['is_active'] = True
filters['automatic_crawling'] = True
if None is not user_id:
filters['id'] = user_id
users = UserController().read(**filters).all()
try:
feed_id = int(feed_id)
except:
feed_id = None
logger.info('Starting crawler.')
start = datetime.now()
loop = asyncio.get_event_loop()
for user in users:
default_crawler.retrieve_feed(loop, user, feed_id)
loop.close()
end = datetime.now()
logger.info('Crawler finished in {} seconds.' \
.format((end - start).seconds))
if __name__ == '__main__':
manager.run()
|
