tubing.ext package¶

Submodules¶

tubing.ext.elasticsearch module¶

tubing.ext.elasticsearch.BulkUpdate(base_url, index, username=None, password=None, chunks_per_post=512, fail_on_error=True)¶: Docs per post is source.chunk_size * chunks_per_post.

class tubing.ext.elasticsearch.DocUpdate(doc, doc_type, esid=None, parent_esid=None, doc_as_upsert=True)¶

Bases: object

DocUpdate is an ElasticSearch document update object. It is meant to be used with BulkBatcher and returns an action and update.

action(encoding)¶

serialize(encoding)¶

update(encoding)¶

exception tubing.ext.elasticsearch.ElasticSearchError¶

Bases: exceptions.Exception

ElasticSearchError message is the text response from the elasticsearch server.

class tubing.ext.elasticsearch.Scroller(base_url, index, typ, query, timeout='10m', scroll_id=None, username=None, password=None)¶

Bases: object

get_hits()¶

tubing.ext package¶

Submodules¶

tubing.ext.elasticsearch module¶

tubing.ext.s3 module¶

Module contents¶