Skip to content

Latest commit

 

History

History
326 lines (260 loc) · 13 KB

api.rst

File metadata and controls

326 lines (260 loc) · 13 KB

warcprox API

Means of interacting with warcprox over http, aside from simply proxying urls.

If warcprox is running at localhost:8000, http://localhost:8000/status returns a json blob with a bunch of status info. For example:

$ curl -sS http://localhost:8000/status
{
  "role": "warcprox",
  "version": "2.4b3.dev189",
  "host": "ayutla.local",
  "address": "127.0.0.1",
  "port": 8000,
  "pid": 60555,
  "threads": 100,
  "active_requests": 1,
  "unaccepted_requests": 0,
  "load": 0.0,
  "queued_urls": 0,
  "queue_max_size": 500,
  "urls_processed": 0,
  "warc_bytes_written": 0,
  "start_time": "2018-10-30T20:15:19.929861Z",
  "rates_1min": {
    "actual_elapsed": 61.76024103164673,
    "urls_per_sec": 0.0,
    "warc_bytes_per_sec": 0.0
  },
  "rates_5min": {
    "actual_elapsed": 1.7602601051330566,
    "urls_per_sec": 0.0,
    "warc_bytes_per_sec": 0.0
  },
  "rates_15min": {
    "actual_elapsed": 1.7602710723876953,
    "urls_per_sec": 0.0,
    "warc_bytes_per_sec": 0.0
  },
  "earliest_still_active_fetch_start": "2018-10-30T20:15:21.691467Z",
  "seconds_behind": 0.001758,
  "postfetch_chain": [
    {
      "processor": "DedupLoader",
      "queued_urls": 0
    },
    {
      "processor": "WarcWriterProcessor",
      "queued_urls": 0
    },
    {
      "processor": "DedupDb",
      "queued_urls": 0
    },
    {
      "processor": "StatsProcessor",
      "queued_urls": 0
    },
    {
      "processor": "RunningStats",
      "queued_urls": 0
    }
  ]

To make warcprox write an arbitrary warc record you can send it a special request with http method WARCPROX_WRITE_RECORD. The http request must include the headers WARC-Type, Content-Type, and Content-Length. Warcprox will use these to populate the warc record. For example:

$ ncat --crlf 127.0.0.1 8000 <<EOF
> WARCPROX_WRITE_RECORD special://url/some?thing HTTP/1.1
> WARC-Type: resource
> Content-type: text/plain;charset=utf-8
> Content-length: 29
>
> i am a warc record payload!
> EOF
HTTP/1.0 204 OK
Server: BaseHTTP/0.6 Python/3.6.3
Date: Tue, 22 May 2018 19:21:02 GMT

On success warcprox responds with http status 204. For the request above warcprox will write a warc record that looks like this:

WARC/1.0
WARC-Type: resource
WARC-Record-ID: <urn:uuid:d0e10852-b18c-4037-a99e-f41915fec5b5>
WARC-Date: 2018-05-21T23:33:31Z
WARC-Target-URI: special://url/some?thing
WARC-Block-Digest: sha1:a282cfe127ab8d51b315ff3d31de18614979d0df
WARC-Payload-Digest: sha1:a282cfe127ab8d51b315ff3d31de18614979d0df
Content-Type: text/plain;charset=utf-8
Content-Length: 29

i am a warc record payload!

Warcprox-Meta is a special http request header that can be used to pass configuration information and metadata with each proxy request to warcprox. The value is a json blob. There are several fields understood by warcprox, and arbitrary additional fields can be included. If warcprox doesn't recognize a field it simply ignores it. Custom fields may be useful for custom warcprox plugins (see README.rst#plugins).

Warcprox strips the warcprox-meta header out before sending the request to remote server, and does not write it in the warc request record.

Brozzler knows about warcprox-meta. For information on configuring it in brozzler, see https://github.com/internetarchive/brozzler/blob/master/job-conf.rst#warcprox-meta. Warcprox-Meta is often a very important part of brozzler job configuration. It is the way url and data limits on jobs, seeds, and hosts are implemented, among other things.

Specifies a warc filename prefix. Warcprox will write the warc record for this capture, if any, to a warc named accordingly.

Example:

Warcprox-Meta: {"warc-prefix": "special-warc"}

Specifies the deduplication bucket(s). For more information about deduplication see README.rst#deduplication.

Examples:

Warcprox-Meta: {"dedup-buckets":{"my-dedup-bucket":"rw"}}

Warcprox-Meta: {"dedup-buckets":{"my-dedup-bucket":"rw", "my-read-only-dedup-bucket": "ro"}}

List of url match rules. Url match rules are somewhat described at https://github.com/internetarchive/brozzler/blob/master/job-conf.rst#scoping and https://github.com/iipc/urlcanon/blob/e2ab3524e/python/urlcanon/rules.py#L70. (TODO: write a better doc and link to it)

Example:

Warcprox-Meta: {"blocks": [{"ssurt": "com,example,//http:/"}, {"domain": "malware.us", "substring": "wp-login.php?action=logout"}]}

If any of the rules match the url being requested, warcprox aborts normal processing and responds with a http 403. The http response includes a Warcprox-Meta response header with one field, blocked-by-rule, which reproduces the value of the match rule that resulted in the block. The presence of the warcprox-meta response header can be used by the client to distinguish this type of a response from a 403 from the remote site.

An example:

$ curl -iksS --proxy localhost:8000 --header 'Warcprox-Meta: {"blocks": [{"ssurt": "com,example,//http:/"}, {"domain": "malware.us", "substring": "wp-login.php?action=logout"}]}' http://example.com/foo
HTTP/1.0 403 Forbidden
Server: BaseHTTP/0.6 Python/3.6.3
Date: Fri, 25 May 2018 22:46:42 GMT
Content-Type: text/plain;charset=utf-8
Connection: close
Content-Length: 111
Warcprox-Meta: {"blocked-by-rule":{"ssurt":"com,example,//http:/"}}

request rejected by warcprox: blocked by rule found in Warcprox-Meta header: {"ssurt": "com,example,//http:/"}

You might be wondering why blocks is necessary. Why would the warcprox client make a request that it should already know will be blocked by the proxy? The answer is that the request may be initiated somewhere where it's difficult to evaluate the block rules. In particular, this circumstance prevails when the browser controlled by brozzler is requesting images, javascript, css, and so on, embedded in a page.

If the blocks header is large, it may be useful or necessary to compress it. compressed_blocks is a string containing a zlib and base64-encoded blocks list. If both blocks and compressed_blocks are provided, warcprox will use the value of compressed_blocks, however this behavior is not guaranteed.

Example:

Warcprox-Meta: {"compressed_blocks": "eJwVykEKgCAQQNGryKwt90F0kGgxlZSgzuCMFIR3r7b//fkBkVoUBgMbJetvTBy9de5U5cFBs+aBnRKG/D8J44XF91XAGpC6ipaQj58u7iIdIfd88oSbBsrjF6gqtOUFJ5YjwQ=="}

Is equivalent to:

{"blocks": [{"ssurt": "com,example,//http:/"}, {"domain": "malware.us", "substring": "wp-login.php?action=logout"}]}

stats is a dictionary with only one field understood by warcprox, buckets. The value of buckets is a list of strings and/or dictionaries. A string signifies the name of the bucket; a dictionary is expected to have at least an item with key bucket whose value is the name of the bucket. The other currently recognized key is tally-domains, which if supplied should be a list of domains. This instructs warcprox to additionally tally substats of the given bucket by domain.

See README.rst#statistics for more information on statistics kept by warcprox.

Examples:

Warcprox-Meta: {"stats":{"buckets":["my-stats-bucket","all-the-stats"]}}
Warcprox-Meta: {"stats":{"buckets":["bucket1",{"bucket":"bucket2","tally-domains":["foo.bar.com","192.168.10.20"}]}}

Domain stats are stored in the stats table under the key "bucket2:foo.bar.com" for the latter example. See the following two sections for more examples. The soft-limits section has an example of a limit on a domain specified in tally-domains.

Specifies quantitative limits for warcprox to enforce. The structure of the dictionary is {stats_key: numerical_limit, ...} where stats key has the format "bucket/sub-bucket/statistic". See README.rst#statistics for further explanation of what "bucket", "sub-bucket", and "statistic" mean here.

If processing a request would result in exceeding a limit, warcprox aborts normal processing and responds with a http 420 Reached Limit. The http response includes a Warcprox-Meta response header with the complete set of statistics for the bucket whose limit has been reached.

Example:

Warcprox-Meta: {"stats": {"buckets": ["test_limits_bucket"]}, "limits": {"test_limits_bucket/total/urls": 10}}
$ curl -iksS --proxy localhost:8000 --header 'Warcprox-Meta: {"stats": {"buckets": ["test_limits_bucket"]}, "limits": {"test_limits_bucket/total/urls": 10}}' http://example.com/foo
HTTP/1.0 420 Reached limit
Server: BaseHTTP/0.6 Python/3.6.3
Date: Fri, 25 May 2018 23:08:32 GMT
Content-Type: text/plain;charset=utf-8
Connection: close
Content-Length: 77
Warcprox-Meta: {"stats":{"test_limits_bucket":{"bucket":"test_limits_bucket","total":{"urls":10,"wire_bytes":15840},"new":{"urls":0,"wire_bytes":0},"revisit":{"urls":10,"wire_bytes":15840}}},"reached-limit":{"test_limits_bucket/total/urls":10}}

request rejected by warcprox: reached limit test_limits_bucket/total/urls=10

From warcprox's perspective soft-limits work almost exactly the same way as limits. The only difference is that when a soft limit is hit, warcprox response with an http 430 Reached soft limit instead of http 420.

Warcprox clients might treat a 430 very differently from a 420. From brozzler's perspective, for instance, soft-limits are very different from limits. When brozzler receives a 420 from warcprox because a limit has been reached, this means that crawling for that seed is finished, and brozzler sets about finalizing the crawl of that seed. On the other hand, brozzler blissfully ignores 430 responses, because soft limits only apply to a particular bucket (like a domain), and don't have any effect on crawling of urls that don't fall in that bucket.

Example:

Warcprox-Meta: {"stats": {"buckets": [{"bucket": "test_domain_doc_limit_bucket", "tally-domains": ["foo.localhost"]}]}, "soft-limits": {"test_domain_doc_limit_bucket:foo.localhost/total/urls": 10}}
$ curl -iksS --proxy localhost:8000 --header 'Warcprox-Meta: {"stats": {"buckets": ["test_limits_bucket"]}, "soft-limits": {"test_limits_bucket/total/urls": 10}}' http://example.com/foo
HTTP/1.0 430 Reached soft limit
Server: BaseHTTP/0.6 Python/3.6.3
Date: Fri, 25 May 2018 23:12:06 GMT
Content-Type: text/plain;charset=utf-8
Connection: close
Content-Length: 82
Warcprox-Meta: {"stats":{"test_limits_bucket":{"bucket":"test_limits_bucket","total":{"urls":10,"wire_bytes":15840},"new":{"urls":0,"wire_bytes":0},"revisit":{"urls":10,"wire_bytes":15840}}},"reached-soft-limit":{"test_limits_bucket/total/urls":10}}

request rejected by warcprox: reached soft limit test_limits_bucket/total/urls=10

An arbitrary dictionary. Warcprox mostly ignores this. The one exception is that if it has a seed entry and crawl logs are enabled via the --crawl-log-dir command line option, the value of seed is written to the crawl log as the 11th field on the line, simulating heritrix's "source tag".

Example:

Warcprox-Meta: {"metadata": {"seed": "http://example.com/seed", "description": "here's some information about this crawl job. blah blah"}

Specifies fields that the client would like to receive in the Warcprox-Meta response header. Only one value is currently understood, capture-metadata.

Example:

Warcprox-Meta: {"accept": ["capture-metadata"]}

The response will include a Warcprox-Meta response header with one field also called captured-metadata. Currently warcprox reports one piece of capture medata, timestamp, which represents the time fetch began for the resource and matches the WARC-Date written to the warc record. For example:

Warcprox-Meta: {"capture-metadata":{"timestamp":"2018-05-30T00:22:49Z"}}

In some cases warcprox will add a Warcprox-Meta header to the http response that it sends to the client. As with the request header, the value is a json blob. It is only included if something in the warcprox-meta request header calls for it. Those cases are described above in the Warcprox-Meta http request header section.