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信息 |