Skip to main content

Confluent Cloud API SDK

Project description

SDK to interact with Confluent Cloud API

Installation

pip install confluent-cloud-sdk

Imports

To use Confluent Admin API SDK in a project

from confluent_cloud_sdk.client_factory import ConfluentClient
from confluent_cloud_sdk.confluent_iam_v2 import ApiKey
from confluent_cloud_sdk.confluent_iam_v2 import ServiceAccount

Initialize connection

client = ConfluentClient(
    "cloud_key_key",
    "cloud_key_secret",
)

Example with secret in AWS And list all assets

import json
from os import environ

from boto3.session import Session
from confluent_cloud_sdk.client_factory import ConfluentClient
from confluent_cloud_sdk.confluent_iam_v2 import ServiceAccount
from confluent_cloud_sdk.confluent_org_v2 import ConfluentEnvironment
from confluent_cloud_sdk.confluent_cluster_v2 import KafkaClusterV2

from compose_x_common.aws import get_session


def get_confluent_admin_secret(
    secret_arn: str,
    session: Session = None,
    key_id: str = "ApiKey",
    secret_id: str = "ApiSecret",
) -> ConfluentClient:
    session = get_session(session)
    client = session.client("secretsmanager")
    value = json.loads(client.get_secret_value(SecretId=secret_arn)["SecretString"])
    return ConfluentClient(value[key_id], value[secret_id])


cclient = get_confluent_admin_secret(environ.get("SECRET_ARN"))

envs = cclient.list_all(ConfluentEnvironment)

for env in envs:
    print(env.obj_id)
    clusters = cclient.list_all(KafkaClusterV2, url_args=f"?environment={env.obj_id}")
    for cluster in clusters:
        print(cluster.obj_id)

svc_accounts = cclient.list_all(ServiceAccount)
for svc_account in svc_accounts:
    print(svc_account.obj_id)
    svc_account.import_api_keys()
    print([key.obj_id for key in svc_account.api_keys.values()])

Usage examples

For more details, see docs/usage.rst

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

confluent_cloud_sdk-0.2.3.tar.gz (14.6 kB view details)

Uploaded Source

Built Distribution

confluent_cloud_sdk-0.2.3-py3-none-any.whl (18.4 kB view details)

Uploaded Python 3

File details

Details for the file confluent_cloud_sdk-0.2.3.tar.gz.

File metadata

  • Download URL: confluent_cloud_sdk-0.2.3.tar.gz
  • Upload date:
  • Size: 14.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.5.1 CPython/3.11.5 Linux/6.4.12-100.fc37.x86_64

File hashes

Hashes for confluent_cloud_sdk-0.2.3.tar.gz
Algorithm Hash digest
SHA256 a8280ae04019c73a6769bf7170096b722b82a7875b8a33c049db01f1ba6abc6e
MD5 51dbdae2738f90aa76e15c485fc0a934
BLAKE2b-256 8fed22b6876833271b46fc999cfe91b86e28808292b253a0bc4a83d55b8093c0

See more details on using hashes here.

File details

Details for the file confluent_cloud_sdk-0.2.3-py3-none-any.whl.

File metadata

  • Download URL: confluent_cloud_sdk-0.2.3-py3-none-any.whl
  • Upload date:
  • Size: 18.4 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.5.1 CPython/3.11.5 Linux/6.4.12-100.fc37.x86_64

File hashes

Hashes for confluent_cloud_sdk-0.2.3-py3-none-any.whl
Algorithm Hash digest
SHA256 c11e10d28e956742c1b4138e9220befdd47d1e5a34e8c3be56155f95ebe95ece
MD5 19f23913f8eaa0704f2d8308cd1aa7e5
BLAKE2b-256 7bfad1b7254d13426936be4e763eed6c2a5dc0f8aa678f765de9bbac0dedb920

See more details on using hashes here.

Supported by

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