Kafka
# Kafka 公开API目录
# API概览
Kafka产品提供以下相关API接口。
# 实例
API | 描述 |
---|---|
GetKafkaList | 获取Kafka实例列表 |
# 访问地址
地区 | 访问地址 |
---|---|
中国大陆 | cdsapi.capitalonline.net |
亚太地区 | cdsapi-asia.capitalonline.net |
欧美地区 | cdsapi-us.capitalonline.net |
# 1.GetKafkaList
Action: GetKafkaList
描述: 获取Kafka实例列表
请求地址: cdsapi.capitalonline.net/kafka
请求方法: POST
请求参数:
参数名 | 必选 | 类型 | 说明 |
---|---|---|---|
RegionId | 否 | string | 站点编号 |
VdcId | 否 | string | 数据中心的编号 |
ProjectId | 否 | string | 项目编号 |
InstanceId | 否 | list | 目标实例编号列表 |
请求示例:
def get_kafka_list():
"""
获取Kafka实例列表
"""
action = "GetKafkaList"
method = "POST"
param = {
}
url = get_signature(action, self.AK, self.AccessKeySecret, method, self.KafkaUrl, param)
body = {
"ProjectId": "b9661xxx-59fe-11eb-b7e7-46d055d59xxx",
"RegionId": "APAC_Singapore_D",
"InstanceId": ["94c08xxx-6095-11eb-b408-0242ac11xxxx"]
}
res = requests.post(url, json=body)
print(res.content)
result = json.loads(res.content)
print(result)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
返回示例:
{
"Code": "Success",
"Data": [
{
"CreateTime": "2021-03-05 15:22:48",
"DiskSize": 100,
"DiskType": "ssd_disk",
"Endpoint": "xxxxxx1.kafka.yun-paas.com.:9093,xxxxxxxx2.kafka.yun-paas.com.:9093,xxxxxxxx3.kafka.yun-paas.com.:9093",
"ExpiredTime": "2099-01-01T00:00:00Z",
"InstanceDeployType": "公网",
"InstanceId": "968f8714-7d83-11eb-8946-xxxxxxxxxx",
"InstanceName": "Test",
"IopsPkg": "1个",
"KafkaSpec": "4C8G",
"KafkaVersion": "v2.2.0",
"MsgRetain": "24小时",
"NodeNumber": 3,
"NodesList": [
{
"BrokerId": 1,
"CreateTime": "2021-03-05 15:22:48",
"NodeId": "0322b342-5ec3-4511-9397-xxxxxxxxxx",
"NodeSpec": "4C8G",
"NodeStatus": "run",
"PrivateIP": "10.240.xx.xx",
"UpdateTime": "2021-03-05 15:27:26"
},
{
"BrokerId": 2,
"CreateTime": "2021-03-05 15:22:48",
"NodeId": "1865d66b-c84d-4b87-bcfa-xxxxxxxxxx",
"NodeSpec": "4C8G",
"NodeStatus": "run",
"PrivateIP": "10.240.xx.xx",
"UpdateTime": "2021-03-05 15:27:26"
},
{
"BrokerId": 3,
"CreateTime": "2021-03-05 15:22:48",
"NodeId": "9be45f93-6818-4ed1-bad9-xxxxxxxxxx",
"NodeSpec": "4C8G",
"NodeStatus": "run",
"PrivateIP": "10.240.xx.xx",
"UpdateTime": "2021-03-05 15:27:26"
}
],
"PayType": "按需",
"RegionId": "CN_Guangzhou_A",
"RegionName": "中国大陆-广州-可用区A",
"ServiceStatus": "run",
"UpdateTime": "2021-03-05 15:27:26",
"VdcId": "4538821a-5bea-42be-b255-xxxxxxxxxx",
"VdcName": "TestGuangZhou"
}
],
"Message": "获取kafka集群列表成功!"
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
返回参数说明:
参数名 | 类型 | 说明 |
---|---|---|
Code | string | 状态码 |
Data | dict | 数据 |
CreateTime | string | 创建时间 |
DiskSize | int | 磁盘大小 |
DiskType | string | 磁盘类型 |
Endpoint | string | 链接地址 |
ExpiredTime | string | 过期时间 |
InstanceId | string | 实例ID |
InstanceName | string | 名称 |
IopsPkg | string | IO增强包数量 |
KafkaSpec | string | 实例规格 |
KafkaVersion | string | 实例版本 |
MsgRetain | string | 消息保留时长 |
NodeNumber | string | 节点数量 |
NodesList | list | 节点列表 |
BrokerId | int | Broker ID |
NodeId | string | 节点ID |
NodeSpec | string | 节点规格 |
NodeStatus | string | 节点状态 |
PrivateIP | string | 节点内网IP |
UpdateTime | string | 更新时间 |
PayType | string | 计费类型:按需,包年包月 |
RegionId | string | 可用区ID |
RegionName | string | 可用区名称 |
ServiceStatus | string | 实例状态 |
VdcId | string | VDC ID |
VdcName | string | VDC名称 |
Message | string | 信息描述 |
状态码说明:
错误码 | 错误信息 | 说明 |
---|---|---|
20001 | 参数错误 | 请确认VDC信息 |