Skip to main content

An elasticsearch wrapper that allows to query ES indices

Project description

Useful functions wrapping around Elasticsearch

Connect to the server with a read-only account

Get access to the indices

from wimbd.es import es_init
es = es_init()

Find out which indices exist (with other information about the index)

from wimbd.es import get_indices

# This returns all indices, along with their total document counts.
print(get_indices())

# This also returns elasticsearch mapping information.
print(get_indices(return_mapping=True))

Note that the get_indices function won't work with the access key we provide, since it limits the access to the ES index. However, you can find the names of the relevant indices below.

At the moment, this will return the following indices:

{'re_pile': {'docs.count': '211036967'},
 're_laion2b_multi': {'docs.count': '2248498161'}
 'openwebtext': {'docs.count': '8013769'},
 're_laion2b-en-1': {'docs.count': '1161075864'},
 're_laion2b-en-2': {'docs.count': '1161076588'},
 'c4': {'docs.count': '1074273501'},
 're_laion2b_nolang': {'docs.count': '1271703630'},
 're_oscar': {'docs.count': '431992659'}}

Different Indices

We have 3 different indices that we can make publicly available. Each contain different corpora:

  • The Pile, OpenWebText, C4 and Oscar (re_pile, openwebtext, c4, and re_oscar)
  • RedPajamav1 (redpajama-split)
  • Dolma (docs_v1.5_2023-11-02)

Indices Mapping

{
    'mappings': {
        'dynamic': 'false',
        'properties': {
            'date': {
                'type': 'date'
            },
            'subset': {
                'type': 'keyword', 
                'ignore_above': 256
            },
            'text': {
                'type': 'text'
            },
            'url': {
                'type': 'text'
            }
        }
    }
}

Search over one index

Search for one or more terms, or sequences of terms (phrases). When you search for a sequence of terms, their exact order is matched.

from wimbd.es import count_documents_containing_phrases

# Count the number of documents containing the term "legal".
count_documents_containing_phrases("test-index", "legal")  # single term

# Count the number of documents containing the term "legal" OR the term "license".
count_documents_containing_phrases("test-index", ["legal", "license"])  # list of terms

# Count the number of documents containing the phrase "terms of use" OR "legally binding".
count_documents_containing_phrases("test-index", ["terms of use", "legally binding"])  # list of word sequences

# Count the number of documents containing both `winter` AND `spring` in the text.
count_documents_containing_phrases("test-index", ["winter", "spring"], all_phrases=True)

If you want to actually inspect the documents, you can use get_documents_containing_phrases with the same queries as above instead.

from wimbd.es import get_documents_containing_phrases

# Get documents containing the term "legal".
get_documents_containing_phrases("test-index", "legal")  # single term

# Specify the number of documents to return using `num_documents`. Default is 10.
# Get documents containing the term "legal" OR the term "license".
get_documents_containing_phrases("test-index", ["legal", "license"], num_documents=50)  # list of terms

# Get documents containing the phrase "terms of use" OR "legally binding".
get_documents_containing_phrases("test-index", ["terms of use", "legally binding"])  # list of word sequences

# Get documents containing both `winter` AND `spring` in the text.
get_documents_containing_phrases("test-index", ["winter", "spring"], all_phrases=True)

Get total number of a term's occurrences (as opposed to document counts)

from wimbd.es import count_total_occurrences_of_unigrams

count_total_occurrences_of_unigrams("test-index", ["legal", "license"])

Search over multiple indices

Because LAION has more documents than can fit into one Elastic Search index, it is split over multiple indices. Fortunately, you can query more than one index at a time.

from wimbd.es import count_documents_containing_phrases

count_documents_containing_phrases("re_laion2b-en-*", "the woman")

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

wimbd-0.1.0.tar.gz (18.5 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

wimbd-0.1.0-py3-none-any.whl (17.8 kB view details)

Uploaded Python 3

File details

Details for the file wimbd-0.1.0.tar.gz.

File metadata

  • Download URL: wimbd-0.1.0.tar.gz
  • Upload date:
  • Size: 18.5 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/5.1.1 CPython/3.9.13

File hashes

Hashes for wimbd-0.1.0.tar.gz
Algorithm Hash digest
SHA256 02cf3e5d944037946c82f3440a41d303b532494152d18ec248a0f7c4d1926a31
MD5 2b3ddac403991986f7ae6fe5825e7339
BLAKE2b-256 03f75cac57af09abe8c903e7e142d4369687f7d6dccbfad2ccfe0096222b599d

See more details on using hashes here.

File details

Details for the file wimbd-0.1.0-py3-none-any.whl.

File metadata

  • Download URL: wimbd-0.1.0-py3-none-any.whl
  • Upload date:
  • Size: 17.8 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/5.1.1 CPython/3.9.13

File hashes

Hashes for wimbd-0.1.0-py3-none-any.whl
Algorithm Hash digest
SHA256 f76da7aa02c3a0de00193a311f893f3d996d42f846434ae8421db14f8b0c30ba
MD5 04d38917f8f1cbed110d8e9d9a7de64f
BLAKE2b-256 7b37d87f78358dcbe73728584fc9f77f47dd0edcb335f29fdb390960bdc0ef5b

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page