from elasticsearch import Elasticsearch

# Initialize the Elasticsearch client
es = Elasticsearch(
    [
        "https://elastic:8oKIqy312EBsAPzWT64NUzji@scic-elasticsearch.es.us-central1.gcp.cloud.es.io:443"
    ]
)

org_name = "organization_level_token_count"

org_tokens = es.search(
    index=org_name,
    body={
        "query": {
            "match": {
                "organization_name": "Risk & Insurance Education Alliance",
            }
        }
    },
)["hits"]["hits"]


if org_tokens:
    for doc in org_tokens:
        doc_source = doc["_source"]
        print("doc_source", doc_source)