- 필수 기능
- 시작하기
- Glossary
- 표준 속성
- Guides
- Agent
- 통합
- 개방형텔레메트리
- 개발자
- Administrator's Guide
- API
- Datadog Mobile App
- CoScreen
- Cloudcraft
- 앱 내
- 서비스 관리
- 인프라스트럭처
- 애플리케이션 성능
- APM
- Continuous Profiler
- 스팬 시각화
- 데이터 스트림 모니터링
- 데이터 작업 모니터링
- 디지털 경험
- 소프트웨어 제공
- 보안
- AI Observability
- 로그 관리
- 관리
Manage your Datadog Confluent Cloud integration accounts and account resources directly through the Datadog API. See the Confluent Cloud page for more information.
PATCH https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}
Update a Confluent resource with the provided resource id for the account associated with the provided account ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
resource_id [required]
string
Confluent Account Resource ID.
Confluent payload
항목
유형
설명
data [required]
object
JSON:API request for updating a Confluent resource.
attributes [required]
object
Attributes object for updating a Confluent resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with a Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"enable_custom_metrics": false,
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource-id-123",
"type": "confluent-cloud-resources"
}
}
OK
Response schema when interacting with a Confluent resource.
항목
유형
설명
data
object
Confluent Cloud resource data.
attributes [required]
object
Model representation of a Confluent Cloud resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with the Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource_id_abc123",
"type": "confluent-cloud-resources"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
Update resource in Confluent account returns "OK" response
"""
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
from datadog_api_client.v2.model.confluent_resource_request import ConfluentResourceRequest
from datadog_api_client.v2.model.confluent_resource_request_attributes import ConfluentResourceRequestAttributes
from datadog_api_client.v2.model.confluent_resource_request_data import ConfluentResourceRequestData
from datadog_api_client.v2.model.confluent_resource_type import ConfluentResourceType
body = ConfluentResourceRequest(
data=ConfluentResourceRequestData(
attributes=ConfluentResourceRequestAttributes(
enable_custom_metrics=False,
resource_type="kafka",
tags=[
"myTag",
"myTag2:myValue",
],
),
id="resource-id-123",
type=ConfluentResourceType.CONFLUENT_CLOUD_RESOURCES,
),
)
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
response = api_instance.update_confluent_resource(account_id="account_id", resource_id="resource_id", body=body)
print(response)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
GET https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}
Get a Confluent resource with the provided resource id for the account associated with the provided account ID.
This endpoint requires the integrations_read
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
resource_id [required]
string
Confluent Account Resource ID.
OK
Response schema when interacting with a Confluent resource.
항목
유형
설명
data
object
Confluent Cloud resource data.
attributes [required]
object
Model representation of a Confluent Cloud resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with the Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource_id_abc123",
"type": "confluent-cloud-resources"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
Get resource from Confluent account returns "OK" response
"""
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
response = api_instance.get_confluent_resource(
account_id="account_id",
resource_id="resource_id",
)
print(response)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
DELETE https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources/{resource_id}
Delete a Confluent resource with the provided resource id for the account associated with the provided account ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
resource_id [required]
string
Confluent Account Resource ID.
OK
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
Delete resource from Confluent account returns "OK" response
"""
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
api_instance.delete_confluent_resource(
account_id="account_id",
resource_id="resource_id",
)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
POST https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources
Create a Confluent resource for the account associated with the provided ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
Confluent payload
항목
유형
설명
data [required]
object
JSON:API request for updating a Confluent resource.
attributes [required]
object
Attributes object for updating a Confluent resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with a Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
],
"enable_custom_metrics": false
},
"id": "exampleconfluentcloud",
"type": "confluent-cloud-resources"
}
}
OK
Response schema when interacting with a Confluent resource.
항목
유형
설명
data
object
Confluent Cloud resource data.
attributes [required]
object
Model representation of a Confluent Cloud resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with the Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": {
"attributes": {
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource_id_abc123",
"type": "confluent-cloud-resources"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
Add resource to Confluent account returns "OK" response
"""
from os import environ
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
from datadog_api_client.v2.model.confluent_resource_request import ConfluentResourceRequest
from datadog_api_client.v2.model.confluent_resource_request_attributes import ConfluentResourceRequestAttributes
from datadog_api_client.v2.model.confluent_resource_request_data import ConfluentResourceRequestData
from datadog_api_client.v2.model.confluent_resource_type import ConfluentResourceType
# there is a valid "confluent_account" in the system
CONFLUENT_ACCOUNT_DATA_ID = environ["CONFLUENT_ACCOUNT_DATA_ID"]
body = ConfluentResourceRequest(
data=ConfluentResourceRequestData(
attributes=ConfluentResourceRequestAttributes(
resource_type="kafka",
tags=[
"myTag",
"myTag2:myValue",
],
enable_custom_metrics=False,
),
id="exampleconfluentcloud",
type=ConfluentResourceType.CONFLUENT_CLOUD_RESOURCES,
),
)
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
response = api_instance.create_confluent_resource(account_id=CONFLUENT_ACCOUNT_DATA_ID, body=body)
print(response)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
GET https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resourceshttps://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}/resources
Get a Confluent resource for the account associated with the provided ID.
This endpoint requires the integrations_read
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
OK
Response schema when interacting with a list of Confluent resources.
항목
유형
설명
data
[object]
The JSON:API data attribute.
attributes [required]
object
Model representation of a Confluent Cloud resource.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
The ID associated with the Confluent resource.
type [required]
enum
The JSON:API type for this request.
Allowed enum values: confluent-cloud-resources
default: confluent-cloud-resources
{
"data": [
{
"attributes": {
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "resource_id_abc123",
"type": "confluent-cloud-resources"
}
]
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
List Confluent Account resources returns "OK" response
"""
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
response = api_instance.list_confluent_resource(
account_id="account_id",
)
print(response)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
PATCH https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}
Update the Confluent account with the provided account ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
Confluent payload
항목
유형
설명
data [required]
object
Data object for updating a Confluent account.
attributes [required]
object
Attributes object for updating a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
api_secret [required]
string
The API secret associated with your Confluent account.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"api_secret": "update-secret",
"tags": [
"updated_tag:val"
]
},
"type": "confluent-cloud-accounts"
}
}
OK
The expected response schema when getting a Confluent account.
항목
유형
설명
data
object
An API key and API secret pair that represents a Confluent account.
attributes [required]
object
The attributes of a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
A randomly generated ID associated with a Confluent account.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "account_id_abc123",
"type": "confluent-cloud-accounts"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
Update Confluent account returns "OK" response
"""
from os import environ
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
from datadog_api_client.v2.model.confluent_account_type import ConfluentAccountType
from datadog_api_client.v2.model.confluent_account_update_request import ConfluentAccountUpdateRequest
from datadog_api_client.v2.model.confluent_account_update_request_attributes import (
ConfluentAccountUpdateRequestAttributes,
)
from datadog_api_client.v2.model.confluent_account_update_request_data import ConfluentAccountUpdateRequestData
# there is a valid "confluent_account" in the system
CONFLUENT_ACCOUNT_DATA_ATTRIBUTES_API_KEY = environ["CONFLUENT_ACCOUNT_DATA_ATTRIBUTES_API_KEY"]
CONFLUENT_ACCOUNT_DATA_ID = environ["CONFLUENT_ACCOUNT_DATA_ID"]
body = ConfluentAccountUpdateRequest(
data=ConfluentAccountUpdateRequestData(
attributes=ConfluentAccountUpdateRequestAttributes(
api_key=CONFLUENT_ACCOUNT_DATA_ATTRIBUTES_API_KEY,
api_secret="update-secret",
tags=[
"updated_tag:val",
],
),
type=ConfluentAccountType.CONFLUENT_CLOUD_ACCOUNTS,
),
)
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
response = api_instance.update_confluent_account(account_id=CONFLUENT_ACCOUNT_DATA_ID, body=body)
print(response)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
GET https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}
Get the Confluent account with the provided account ID.
This endpoint requires the integrations_read
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
OK
The expected response schema when getting a Confluent account.
항목
유형
설명
data
object
An API key and API secret pair that represents a Confluent account.
attributes [required]
object
The attributes of a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
A randomly generated ID associated with a Confluent account.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "account_id_abc123",
"type": "confluent-cloud-accounts"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
Get Confluent account returns "OK" response
"""
from os import environ
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
# there is a valid "confluent_account" in the system
CONFLUENT_ACCOUNT_DATA_ID = environ["CONFLUENT_ACCOUNT_DATA_ID"]
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
response = api_instance.get_confluent_account(
account_id=CONFLUENT_ACCOUNT_DATA_ID,
)
print(response)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
DELETE https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}https://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts/{account_id}
Delete a Confluent account with the provided account ID.
This endpoint requires the manage_integrations
permission.
이름
유형
설명
account_id [required]
string
Confluent Account ID.
OK
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
Delete Confluent account returns "OK" response
"""
from os import environ
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
# there is a valid "confluent_account" in the system
CONFLUENT_ACCOUNT_DATA_ID = environ["CONFLUENT_ACCOUNT_DATA_ID"]
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
api_instance.delete_confluent_account(
account_id=CONFLUENT_ACCOUNT_DATA_ID,
)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
POST https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accountshttps://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accountshttps://api.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts
Create a Confluent account.
This endpoint requires the manage_integrations
permission.
Confluent payload
항목
유형
설명
data [required]
object
The data body for adding a Confluent account.
attributes [required]
object
Attributes associated with the account creation request.
api_key [required]
string
The API key associated with your Confluent account.
api_secret [required]
string
The API secret associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with a Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"api_secret": "test-api-secret-123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource-id-123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"type": "confluent-cloud-accounts"
}
}
OK
The expected response schema when getting a Confluent account.
항목
유형
설명
data
object
An API key and API secret pair that represents a Confluent account.
attributes [required]
object
The attributes of a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
A randomly generated ID associated with a Confluent account.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": {
"attributes": {
"api_key": "TESTAPIKEY123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "account_id_abc123",
"type": "confluent-cloud-accounts"
}
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
Add Confluent account returns "OK" response
"""
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
from datadog_api_client.v2.model.confluent_account_create_request import ConfluentAccountCreateRequest
from datadog_api_client.v2.model.confluent_account_create_request_attributes import (
ConfluentAccountCreateRequestAttributes,
)
from datadog_api_client.v2.model.confluent_account_create_request_data import ConfluentAccountCreateRequestData
from datadog_api_client.v2.model.confluent_account_resource_attributes import ConfluentAccountResourceAttributes
from datadog_api_client.v2.model.confluent_account_type import ConfluentAccountType
body = ConfluentAccountCreateRequest(
data=ConfluentAccountCreateRequestData(
attributes=ConfluentAccountCreateRequestAttributes(
api_key="TESTAPIKEY123",
api_secret="test-api-secret-123",
resources=[
ConfluentAccountResourceAttributes(
enable_custom_metrics=False,
id="resource-id-123",
resource_type="kafka",
tags=[
"myTag",
"myTag2:myValue",
],
),
],
tags=[
"myTag",
"myTag2:myValue",
],
),
type=ConfluentAccountType.CONFLUENT_CLOUD_ACCOUNTS,
),
)
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
response = api_instance.create_confluent_account(body=body)
print(response)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"
GET https://api.ap1.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.datadoghq.eu/api/v2/integrations/confluent-cloud/accountshttps://api.ddog-gov.com/api/v2/integrations/confluent-cloud/accountshttps://api.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.us3.datadoghq.com/api/v2/integrations/confluent-cloud/accountshttps://api.us5.datadoghq.com/api/v2/integrations/confluent-cloud/accounts
List Confluent accounts.
This endpoint requires the integrations_read
permission.
OK
Confluent account returned by the API.
항목
유형
설명
data
[object]
The Confluent account.
attributes [required]
object
The attributes of a Confluent account.
api_key [required]
string
The API key associated with your Confluent account.
resources
[object]
A list of Confluent resources associated with the Confluent account.
enable_custom_metrics
boolean
Enable the custom.consumer_lag_offset
metric, which contains extra metric tags.
id
string
The ID associated with the Confluent resource.
resource_type [required]
string
The resource type of the Resource. Can be kafka
, connector
, ksql
, or schema_registry
.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
tags
[string]
A list of strings representing tags. Can be a single key, or key-value pairs separated by a colon.
id [required]
string
A randomly generated ID associated with a Confluent account.
type [required]
enum
The JSON:API type for this API. Should always be confluent-cloud-accounts
.
Allowed enum values: confluent-cloud-accounts
default: confluent-cloud-accounts
{
"data": [
{
"attributes": {
"api_key": "TESTAPIKEY123",
"resources": [
{
"enable_custom_metrics": false,
"id": "resource_id_abc123",
"resource_type": "kafka",
"tags": [
"myTag",
"myTag2:myValue"
]
}
],
"tags": [
"myTag",
"myTag2:myValue"
]
},
"id": "account_id_abc123",
"type": "confluent-cloud-accounts"
}
]
}
Bad Request
API error response.
{
"errors": [
"Bad Request"
]
}
Forbidden
API error response.
{
"errors": [
"Bad Request"
]
}
Not Found
API error response.
{
"errors": [
"Bad Request"
]
}
Too many requests
API error response.
{
"errors": [
"Bad Request"
]
}
"""
List Confluent accounts returns "OK" response
"""
from datadog_api_client import ApiClient, Configuration
from datadog_api_client.v2.api.confluent_cloud_api import ConfluentCloudApi
configuration = Configuration()
with ApiClient(configuration) as api_client:
api_instance = ConfluentCloudApi(api_client)
response = api_instance.list_confluent_account()
print(response)
First install the library and its dependencies and then save the example to example.py
and run following commands:
DD_SITE="datadoghq.comus3.datadoghq.comus5.datadoghq.comdatadoghq.euap1.datadoghq.comddog-gov.com" DD_API_KEY="<API-KEY>" DD_APP_KEY="<APP-KEY>" python3 "example.py"