mirror of
https://github.com/internetarchive/brozzler.git
synced 2025-06-20 12:54:23 -04:00
starting on documenting job configuration
This commit is contained in:
parent
2462efc4ed
commit
8c9a9c5666
7 changed files with 138 additions and 6 deletions
|
@ -95,7 +95,8 @@ Job Configuration
|
||||||
|
|
||||||
Jobs are defined using yaml files. Options may be specified either at the
|
Jobs are defined using yaml files. Options may be specified either at the
|
||||||
top-level or on individual seeds. A job id and at least one seed url
|
top-level or on individual seeds. A job id and at least one seed url
|
||||||
must be specified, everything else is optional.
|
must be specified, everything else is optional. For details, see
|
||||||
|
`<job-conf.rst>`_.
|
||||||
|
|
||||||
::
|
::
|
||||||
|
|
||||||
|
|
|
@ -87,7 +87,7 @@ def new_site(frontier, site):
|
||||||
frontier.new_page(page)
|
frontier.new_page(page)
|
||||||
logging.info("queued page %s", page)
|
logging.info("queued page %s", page)
|
||||||
else:
|
else:
|
||||||
logging.warn("seed url {} is blocked by robots.txt".format(site.seed))
|
logging.warn("seed url %s is blocked by robots.txt", site.seed)
|
||||||
finally:
|
finally:
|
||||||
# finally block because we want to insert the Site no matter what
|
# finally block because we want to insert the Site no matter what
|
||||||
frontier.new_site(site)
|
frontier.new_site(site)
|
||||||
|
|
|
@ -12,8 +12,16 @@
|
||||||
<div>
|
<div>
|
||||||
<h2>Workers</h2>
|
<h2>Workers</h2>
|
||||||
|
|
||||||
|
<p><i>This page depends on some deployment details outside of brozzler
|
||||||
|
itself, namely that port 8901 on each brozzler-worker is running
|
||||||
|
websockify bridging VNC running on the same host. The vagrant+ansible
|
||||||
|
configuration in the brozzler repo contains an example of that.
|
||||||
|
https://github.com/internetarchive/brozzler/tree/master/vagrant
|
||||||
|
</i></p>
|
||||||
|
|
||||||
<div class="row">
|
<div class="row">
|
||||||
<div class="col-xs-12 col-sm-12 col-md-6 col-lg-6" ng-repeat="worker in workers">
|
<div class="col-xs-12 col-sm-12 col-md-6 col-lg-6" ng-repeat="worker in workers">
|
||||||
|
<div>{{worker}}</div>
|
||||||
<div>{{worker.host}}</div>
|
<div>{{worker.host}}</div>
|
||||||
<iframe style="width:45rem;height:32rem;"
|
<iframe style="width:45rem;height:32rem;"
|
||||||
ng-src="{{'/static/noVNC/vnc.html?host=' + worker.host + '&port=8901&autoconnect=1&resize=downscale'}}">
|
ng-src="{{'/static/noVNC/vnc.html?host=' + worker.host + '&port=8901&autoconnect=1&resize=downscale'}}">
|
||||||
|
|
81
job-conf.rst
Normal file
81
job-conf.rst
Normal file
|
@ -0,0 +1,81 @@
|
||||||
|
brozzler job configuration
|
||||||
|
==========================
|
||||||
|
|
||||||
|
Jobs are defined using yaml files. Options may be specified either at the
|
||||||
|
top-level or on individual seeds. A job id and at least one seed url
|
||||||
|
must be specified, everything else is optional.
|
||||||
|
|
||||||
|
an example
|
||||||
|
----------
|
||||||
|
|
||||||
|
::
|
||||||
|
|
||||||
|
id: myjob
|
||||||
|
time_limit: 60 # seconds
|
||||||
|
proxy: 127.0.0.1:8000 # point at warcprox for archiving
|
||||||
|
ignore_robots: false
|
||||||
|
enable_warcprox_features: false
|
||||||
|
warcprox_meta:
|
||||||
|
warc-prefix: job1
|
||||||
|
stats:
|
||||||
|
buckets:
|
||||||
|
- job1-stats
|
||||||
|
metadata: {}
|
||||||
|
seeds:
|
||||||
|
- url: http://one.example.org/
|
||||||
|
warcprox_meta:
|
||||||
|
warc-prefix: job1-seed1
|
||||||
|
stats:
|
||||||
|
buckets:
|
||||||
|
- job1-seed1-stats
|
||||||
|
- url: http://two.example.org/
|
||||||
|
time_limit: 30
|
||||||
|
- url: http://three.example.org/
|
||||||
|
time_limit: 10
|
||||||
|
ignore_robots: true
|
||||||
|
scope:
|
||||||
|
surt: http://(org,example,
|
||||||
|
|
||||||
|
how inheritance works
|
||||||
|
---------------------
|
||||||
|
|
||||||
|
Most of the available options apply to seeds. Such options can also be
|
||||||
|
specified at the top level, in which case the seeds inherit the options. If
|
||||||
|
an option is specified both at the top level and at the level of an individual
|
||||||
|
seed, the results are merged with the seed-level value taking precedence in
|
||||||
|
case of conflicts. It's probably easiest to make sense of this by way of an
|
||||||
|
example.
|
||||||
|
|
||||||
|
In the example yaml above, ``warcprox_meta`` is specified at the top level and
|
||||||
|
at the seed level for the seed http://one.example.org/. At the top level we
|
||||||
|
have::
|
||||||
|
|
||||||
|
warcprox_meta:
|
||||||
|
warc-prefix: job1
|
||||||
|
stats:
|
||||||
|
buckets:
|
||||||
|
- job1-stats
|
||||||
|
|
||||||
|
At the seed level we have::
|
||||||
|
|
||||||
|
warcprox_meta:
|
||||||
|
warc-prefix: job1-seed1
|
||||||
|
stats:
|
||||||
|
buckets:
|
||||||
|
- job1-seed1-stats
|
||||||
|
|
||||||
|
The merged configuration as applied to the seed http://one.example.org/ will
|
||||||
|
be::
|
||||||
|
|
||||||
|
warcprox_meta:
|
||||||
|
warc-prefix: job1-seed1
|
||||||
|
stats:
|
||||||
|
buckets:
|
||||||
|
- job1-stats
|
||||||
|
- job1-seed1-stats
|
||||||
|
|
||||||
|
Notice that:
|
||||||
|
|
||||||
|
- There is a collision on ``warc-prefix`` and the seed-level value wins.
|
||||||
|
- Since ``buckets`` is a list, the merged result includes all the values from
|
||||||
|
both the top level and the seed level.
|
2
setup.py
2
setup.py
|
@ -32,7 +32,7 @@ def find_package_data(package):
|
||||||
|
|
||||||
setuptools.setup(
|
setuptools.setup(
|
||||||
name='brozzler',
|
name='brozzler',
|
||||||
version='1.1b6.dev85',
|
version='1.1b6.dev86',
|
||||||
description='Distributed web crawling with browsers',
|
description='Distributed web crawling with browsers',
|
||||||
url='https://github.com/internetarchive/brozzler',
|
url='https://github.com/internetarchive/brozzler',
|
||||||
author='Noah Levitt',
|
author='Noah Levitt',
|
||||||
|
|
42
vagrant/vagrant-brozzler-new-job.py
Executable file
42
vagrant/vagrant-brozzler-new-job.py
Executable file
|
@ -0,0 +1,42 @@
|
||||||
|
#!/usr/bin/env python
|
||||||
|
'''
|
||||||
|
vagrant-brozzler-new-job.py - runs brozzler-new-job inside the vagrant vm to
|
||||||
|
queue a job for your vagrant brozzler deployment.
|
||||||
|
|
||||||
|
This is a standalone script with no dependencies other than python, and should
|
||||||
|
work with python 2.7 or python 3.2+. The only reason it's not a bash script is
|
||||||
|
so we can use the argparse library.
|
||||||
|
'''
|
||||||
|
|
||||||
|
import sys
|
||||||
|
import os
|
||||||
|
import argparse
|
||||||
|
import subprocess
|
||||||
|
|
||||||
|
def main(argv=[]):
|
||||||
|
arg_parser = argparse.ArgumentParser(prog=os.path.basename(argv[0]))
|
||||||
|
arg_parser.add_argument(
|
||||||
|
'job_conf_file', metavar='JOB_CONF_FILE',
|
||||||
|
help='brozzler job configuration file in yaml')
|
||||||
|
args = arg_parser.parse_args(args=argv[1:])
|
||||||
|
|
||||||
|
with open(args.job_conf_file, 'rb') as f:
|
||||||
|
yaml_bytes = f.read()
|
||||||
|
subprocess.call(
|
||||||
|
['vagrant', 'ssh', '--', 'f=`mktemp` && cat > $f'],
|
||||||
|
stdin=yaml_bytes)
|
||||||
|
|
||||||
|
# cd to path with Vagrantfile so "vagrant ssh" knows what to do
|
||||||
|
os.chdir(os.path.dirname(__file__))
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
main(sys.argv)
|
||||||
|
|
||||||
|
## # cd to path with Vagrantfile so "vagrant ssh" knows what to do
|
||||||
|
## script_dir="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
|
||||||
|
## cd $script_dir
|
||||||
|
##
|
||||||
|
## vagrant ssh -- \
|
||||||
|
## PYTHONPATH=/home/vagrant/brozzler-ve34/lib/python3.4/site-packages \
|
||||||
|
## /home/vagrant/brozzler-ve34/bin/python \
|
||||||
|
## /home/vagrant/brozzler-ve34/bin/brozzler-new-job "$@"
|
|
@ -3,7 +3,7 @@
|
||||||
vagrant-brozzler-new-site.py - runs brozzler-new-site inside the vagrant vm to
|
vagrant-brozzler-new-site.py - runs brozzler-new-site inside the vagrant vm to
|
||||||
queue a site for your vagrant brozzler deployment.
|
queue a site for your vagrant brozzler deployment.
|
||||||
|
|
||||||
Fills in the --proxy option automatically. some other options are passed
|
Fills in the --proxy option automatically. Some other options are passed
|
||||||
through.
|
through.
|
||||||
|
|
||||||
This is a standalone script with no dependencies other than python, and should
|
This is a standalone script with no dependencies other than python, and should
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue