Elasticsearch

1
from composio import Composio
2
from composio.types import auth_scheme
3
4
# Replace these with your actual values
5
elasticsearch_auth_config_id = "ac_YOUR_ELASTICSEARCH_CONFIG_ID"
6
user_id = "user@example.com"
7
username = "your_elasticsearch_username"
8
password = "your_elasticsearch_password"
9
10
composio = Composio()
11
12
# Create a new connected account for Elasticsearch using Basic Auth
13
connection_request = composio.connected_accounts.initiate(
14
    user_id=user_id,
15
    auth_config_id=elasticsearch_auth_config_id,
16
    config=auth_scheme.basic_auth(
17
        username=username,
18
        password=password
19
    )
20
)
21
22
# Basic authentication is immediate - no redirect needed
23
print(f"Successfully connected Elasticsearch for user {user_id}")
24
25
# You can verify the connection using:
26
# connected_account = composio.connected_accounts.get(user_id=user_id, app_id="ELASTICSEARCH")

1
from composio import Composio
2
3
# Replace these with your actual values
4
elasticsearch_auth_config_id = "ac_YOUR_ELASTICSEARCH_CONFIG_ID" # Auth config ID created above
5
user_id = "0000-0000-0000"  # UUID from database/app
6
7
composio = Composio()
8
9
def authenticate_toolkit(user_id: str, auth_config_id: str):
10
    # Replace this with a method to retrieve an API key from the user.
11
    # Or supply your own.
12
    user_api_key = input("[!] Enter API key")
13
14
    connection_request = composio.connected_accounts.initiate(
15
        user_id=user_id,
16
        auth_config_id=auth_config_id,
17
        config={"auth_scheme": "API_KEY", "val": {"generic_api_key": user_api_key}}
18
    )
19
20
    # API Key authentication is immediate - no redirect needed
21
    print(f"Successfully connected Elasticsearch for user {user_id}")
22
    print(f"Connection status: {connection_request.status}")
23
    
24
    return connection_request.id
25
26
27
connection_id = authenticate_toolkit(user_id, elasticsearch_auth_config_id)
28
29
# You can verify the connection using:
30
connected_account = composio.connected_accounts.get(connection_id)
31
print(f"Connected account: {connected_account}")