|
|
import asyncio
|
|
|
import signal
|
|
|
from pysitemap.base_crawler import Crawler
|
|
|
|
|
|
|
|
|
def crawler(
|
|
|
root_url, out_file, out_format='xml',
|
|
|
maxtasks=10, exclude_urls=list, exclude_imgs=list, image_root_urls=list,
|
|
|
verifyssl=True, headers=None, timezone_offset=0, changefreq=None,
|
|
|
priorities=None):
|
|
|
"""
|
|
|
run crowler
|
|
|
:param root_url: Site root url
|
|
|
:param out_file: path to the out file
|
|
|
:param out_format: format of out file [xml, txt]
|
|
|
:param maxtasks: max count of tasks
|
|
|
:param exclude_urls: excludable url paths
|
|
|
:param exclude_imgs: excludable img url paths
|
|
|
:param image_root_urls: recognized image root urls on the domain
|
|
|
:param verifyssl: verify website certificate?
|
|
|
:param headers: Send these headers in every request
|
|
|
:param timezone_offset: timezone offset for lastmod tags
|
|
|
:param changefreq: dictionary, where key is site sub url regex, and value is changefreq
|
|
|
:param priorities: dictionary, where key is site sub url regex, and value is priority float
|
|
|
:return:
|
|
|
"""
|
|
|
loop = asyncio.get_event_loop()
|
|
|
|
|
|
c = Crawler(root_url, out_file=out_file, out_format=out_format,
|
|
|
maxtasks=maxtasks, exclude_urls=exclude_urls, exclude_imgs=exclude_imgs,
|
|
|
image_root_urls=image_root_urls, verifyssl=verifyssl,
|
|
|
headers=headers, timezone_offset=timezone_offset,
|
|
|
changefreq=changefreq, priorities=priorities)
|
|
|
|
|
|
loop.run_until_complete(c.run())
|
|
|
|
|
|
try:
|
|
|
loop.add_signal_handler(signal.SIGINT, loop.stop)
|
|
|
except RuntimeError:
|
|
|
pass
|
|
|
print('todo_queue:', len(c.todo_queue))
|
|
|
print('busy:', len(c.busy))
|
|
|
print('done:', len(c.done), '; ok:', sum(list(zip(*c.done.values()))[0]) )
|
|
|
print('tasks:', len(c.tasks))
|