from elasticsearch import Elasticsearch
es = Elasticsearch()

# ignore 400 cause by IndexAlreadyExistsException when creating an index
es.indices.create(index='test-index', ignore=400)

# ignore 404 and 400
es.indices.delete(index='test-index', ignore=[400, 404])

# only wait for 1 second, regardless of the client's default
es.cluster.health(wait_for_status='yellow', request_timeout=1)

es.search(index='test-index', filter_path=['hits.hits._id', 'hits.hits._type'])

es.search(index='test-index', filter_path=['hits.hits._*'])

class elasticsearch.Elasticsearch(hosts=None, transport_class=<class 'elasticsearch.transport.Transport'>, **kwargs)

# create connection to localhost using the ThriftConnection
es = Elasticsearch(connection_class=ThriftConnection)

# create connection that will automatically inspect the cluster to get
# the list of active nodes. Start with nodes running on 'esnode1' and
# 'esnode2'
es = Elasticsearch(
    ['esnode1', 'esnode2'],
    # sniff before doing anything
    sniff_on_start=True,
    # refresh nodes after a node fails to respond
    sniff_on_connection_fail=True,
    # and also every 60 seconds
    sniffer_timeout=60
)

# connect to localhost directly and another node using SSL on port 443
# and an url_prefix. Note that ``port`` needs to be an int.
es = Elasticsearch([
    {'host': 'localhost'},
    {'host': 'othernode', 'port': 443, 'url_prefix': 'es', 'use_ssl': True},
])

es = Elasticsearch(
    ['localhost:443', 'other_host:443'],
    # turn on SSL
    use_ssl=True,
    # make sure we verify SSL certificates (off by default)
    verify_certs=True,
    # provide a path to CA certs on disk
    ca_certs='/path/to/CA_certs',
    # PEM formatted SSL client certificate
    client_cert='/path/to/clientcert.pem',
    # PEM formatted SSL client key
    client_key='/path/to/clientkey.pem'
)

es = Elasticsearch(
    [
        'http://user:secret@localhost:9200/',
        'https://user:secret@other_host:443/production'
    ],
    verify_certs=True
)

bulk(*args, **kwargs)

clear_scroll(*args, **keargs)

count(*args, **kwargs)

count_percolate(*args, **kwargs)

create(*args, **kwargs)

delete(*args, **kwargs)

delete_script(*args, **kwargs)

delete_template(*args, **kwargs)

exists(*args, **kwargs)

explain(*args, **kwargs)

field_stats(*args, **kwargs)

get(*args, **kwargs)

get_script(*args, **kwargs)

get_source(*args, **kwargs)

get_template(*args, **kwargs)

index(*args, **kwargs)

info(*args, **kwargs)

mget(*args, **kwargs)

mpercolate(*args, **kwargs)

msearch(*args, **kwargs)

mtermvectors(*args, **kwargs)

percolate(*args, **kwargs)

ping(*args, **kwargs)

put_script(*args, **kwargs)

put_template(*args, **kwargs)

render_search_template(*args, **kwargs)

scroll(*args, **kwargs)

search(*args, **kwargs)

search_exists(*args, **kwargs)

search_shards(*args, **kwargs)

search_template(*args, **kwargs)

suggest(*args, **kwargs)

termvectors(*args, **kwargs)

update(*args, **kwargs)

class elasticsearch.ImproperlyConfigured

class elasticsearch.ElasticsearchException

class elasticsearch.SerializationError(ElasticsearchException)

class elasticsearch.TransportError(ElasticsearchException)

class elasticsearch.ConnectionError(TransportError)

class elasticsearch.ConnectionTimeout(ConnectionError)

class elasticsearch.SSLError(ConnectionError)

class elasticsearch.NotFoundError(TransportError)

class elasticsearch.ConflictError(TransportError)

class elasticsearch.RequestError(TransportError)

class elasticsearch.ConnectionError(TransportError)

class elasticsearch.connection.Connection(host='localhost', port=9200, url_prefix='', timeout=10, **kwargs)

class elasticsearch.connection.Urllib3HttpConnection(host='localhost', port=9200, http_auth=None, use_ssl=False, verify_certs=False, ca_certs=None, client_cert=None, client_key=None, ssl_version=None, ssl_assert_hostname=None, ssl_assert_fingerprint=None, maxsize=10, **kwargs)

class elasticsearch.connection.RequestsHttpConnection(host='localhost', port=9200, http_auth=None, use_ssl=False, verify_certs=False, ca_certs=None, client_cert=None, client_key=None, **kwargs)

{
  "_index": "index-name",
  "_type": "document",
  "_id": 42,
  "_parent": 5,
  "_ttl": "1d",
  "_source": {
    "title": "Hello World!",
    "body": "..."
  }
}

{
  "_id": 42,
  "_parent": 5,
  "title": "Hello World!",
  "body": "..."
}

{
    "_op_type": "delete",
    "_index": "index-name",
    "_type": "document",
    "_id": 42
  }
{
    "_op_type": "update",
    "_index": "index-name",
    "_type": "document",
    "_id": 42,
    "doc": {
      "question": "The life, universe and everything."
    }
  }

elasticsearch.helpers.streaming_bulk(client, actions, chunk_size=500, max_chunk_bytes=104857600, raise_on_error=True, expand_action_callback=<function expand_action>, raise_on_exception=True, **kwargs)

elasticsearch.helpers.parallel_bulk(client, actions, thread_count=4, chunk_size=500, max_chunk_bytes=104857600, expand_action_callback=<function expand_action>, **kwargs)

elasticsearch.helpers.bulk(client, actions, stats_only=False, **kwargs)

elasticsearch.helpers.scan(client, query=None, scroll=u'5m', raise_on_error=True, preserve_order=False, **kwargs)

scan(es,
    query={"query": {"match": {"title": "python"}}},
    index="orders-*",
    doc_type="books"
)

elasticsearch.helpers.reindex(client, source_index, target_index, query=None, target_client=None, chunk_size=500, scroll=u'5m', scan_kwargs={}, bulk_kwargs={})