Skip to content

Commit 2f98ef3

Browse files
committed
Add DataService OpenAPIs.
1 parent 9e423cf commit 2f98ef3

File tree

57 files changed

+2324
-1
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

57 files changed

+2324
-1
lines changed

aliyun-python-sdk-dataphin-public/ChangeLog.txt

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,9 @@
1+
2025-07-29 Version: 1.0.10
2+
- Add DataService OpenAPIs.
3+
- Add Udf OpenAPIs.
4+
- Add Project OpenAPIs.
5+
- Add ComputeSource OpenAPIs.
6+
17
2025-06-30 Version: 1.0.9
28
- Add api GetStreamJobs .
39

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = '1.0.9'
1+
__version__ = '1.0.10'
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
#
13+
# Unless required by applicable law or agreed to in writing,
14+
# software distributed under the License is distributed on an
15+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
# KIND, either express or implied. See the License for the
17+
# specific language governing permissions and limitations
18+
# under the License.
19+
20+
from aliyunsdkcore.request import RpcRequest
21+
import json
22+
23+
class AddDataServiceProjectMemberRequest(RpcRequest):
24+
25+
def __init__(self):
26+
RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'AddDataServiceProjectMember')
27+
self.set_protocol_type('https')
28+
self.set_method('POST')
29+
30+
def get_OpTenantId(self): # Long
31+
return self.get_query_params().get('OpTenantId')
32+
33+
def set_OpTenantId(self, OpTenantId): # Long
34+
self.add_query_param('OpTenantId', OpTenantId)
35+
def get_AddCommand(self): # Struct
36+
return self.get_body_params().get('AddCommand')
37+
38+
def set_AddCommand(self, AddCommand): # Struct
39+
self.add_body_params("AddCommand", json.dumps(AddCommand))
40+
def get_ProjectId(self): # Integer
41+
return self.get_query_params().get('ProjectId')
42+
43+
def set_ProjectId(self, ProjectId): # Integer
44+
self.add_query_param('ProjectId', ProjectId)
Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
#
13+
# Unless required by applicable law or agreed to in writing,
14+
# software distributed under the License is distributed on an
15+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
# KIND, either express or implied. See the License for the
17+
# specific language governing permissions and limitations
18+
# under the License.
19+
20+
from aliyunsdkcore.request import RpcRequest
21+
import json
22+
23+
class AddProjectMemberRequest(RpcRequest):
24+
25+
def __init__(self):
26+
RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'AddProjectMember')
27+
self.set_protocol_type('https')
28+
self.set_method('POST')
29+
30+
def get_OpTenantId(self): # Long
31+
return self.get_query_params().get('OpTenantId')
32+
33+
def set_OpTenantId(self, OpTenantId): # Long
34+
self.add_query_param('OpTenantId', OpTenantId)
35+
def get_AddCommand(self): # Struct
36+
return self.get_body_params().get('AddCommand')
37+
38+
def set_AddCommand(self, AddCommand): # Struct
39+
self.add_body_params("AddCommand", json.dumps(AddCommand))
40+
def get_Id(self): # Long
41+
return self.get_query_params().get('Id')
42+
43+
def set_Id(self, Id): # Long
44+
self.add_query_param('Id', Id)
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
#
13+
# Unless required by applicable law or agreed to in writing,
14+
# software distributed under the License is distributed on an
15+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
# KIND, either express or implied. See the License for the
17+
# specific language governing permissions and limitations
18+
# under the License.
19+
20+
from aliyunsdkcore.request import RpcRequest
21+
import json
22+
23+
class ApplyDataServiceApiRequest(RpcRequest):
24+
25+
def __init__(self):
26+
RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'ApplyDataServiceApi')
27+
self.set_protocol_type('https')
28+
self.set_method('POST')
29+
30+
def get_OpTenantId(self): # Long
31+
return self.get_query_params().get('OpTenantId')
32+
33+
def set_OpTenantId(self, OpTenantId): # Long
34+
self.add_query_param('OpTenantId', OpTenantId)
35+
def get_ApplyCommand(self): # Struct
36+
return self.get_body_params().get('ApplyCommand')
37+
38+
def set_ApplyCommand(self, ApplyCommand): # Struct
39+
self.add_body_params("ApplyCommand", json.dumps(ApplyCommand))
40+
def get_ProjectId(self): # Integer
41+
return self.get_query_params().get('ProjectId')
42+
43+
def set_ProjectId(self, ProjectId): # Integer
44+
self.add_query_param('ProjectId', ProjectId)
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
#
13+
# Unless required by applicable law or agreed to in writing,
14+
# software distributed under the License is distributed on an
15+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
# KIND, either express or implied. See the License for the
17+
# specific language governing permissions and limitations
18+
# under the License.
19+
20+
from aliyunsdkcore.request import RpcRequest
21+
import json
22+
23+
class ApplyDataServiceAppRequest(RpcRequest):
24+
25+
def __init__(self):
26+
RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'ApplyDataServiceApp')
27+
self.set_protocol_type('https')
28+
self.set_method('POST')
29+
30+
def get_OpTenantId(self): # Long
31+
return self.get_query_params().get('OpTenantId')
32+
33+
def set_OpTenantId(self, OpTenantId): # Long
34+
self.add_query_param('OpTenantId', OpTenantId)
35+
def get_ApplyCommand(self): # Struct
36+
return self.get_body_params().get('ApplyCommand')
37+
38+
def set_ApplyCommand(self, ApplyCommand): # Struct
39+
self.add_body_params("ApplyCommand", json.dumps(ApplyCommand))
40+
def get_ProjectId(self): # Integer
41+
return self.get_query_params().get('ProjectId')
42+
43+
def set_ProjectId(self, ProjectId): # Integer
44+
self.add_query_param('ProjectId', ProjectId)
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
#
13+
# Unless required by applicable law or agreed to in writing,
14+
# software distributed under the License is distributed on an
15+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
# KIND, either express or implied. See the License for the
17+
# specific language governing permissions and limitations
18+
# under the License.
19+
20+
from aliyunsdkcore.request import RpcRequest
21+
22+
class CheckComputeSourceConnectivityByIdRequest(RpcRequest):
23+
24+
def __init__(self):
25+
RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'CheckComputeSourceConnectivityById')
26+
self.set_protocol_type('https')
27+
self.set_method('POST')
28+
29+
def get_OpTenantId(self): # Long
30+
return self.get_query_params().get('OpTenantId')
31+
32+
def set_OpTenantId(self, OpTenantId): # Long
33+
self.add_query_param('OpTenantId', OpTenantId)
34+
def get_Id(self): # Long
35+
return self.get_query_params().get('Id')
36+
37+
def set_Id(self, Id): # Long
38+
self.add_query_param('Id', Id)
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
#
13+
# Unless required by applicable law or agreed to in writing,
14+
# software distributed under the License is distributed on an
15+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
# KIND, either express or implied. See the License for the
17+
# specific language governing permissions and limitations
18+
# under the License.
19+
20+
from aliyunsdkcore.request import RpcRequest
21+
import json
22+
23+
class CheckComputeSourceConnectivityRequest(RpcRequest):
24+
25+
def __init__(self):
26+
RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'CheckComputeSourceConnectivity')
27+
self.set_protocol_type('https')
28+
self.set_method('POST')
29+
30+
def get_OpTenantId(self): # Long
31+
return self.get_query_params().get('OpTenantId')
32+
33+
def set_OpTenantId(self, OpTenantId): # Long
34+
self.add_query_param('OpTenantId', OpTenantId)
35+
def get_CheckCommand(self): # Struct
36+
return self.get_body_params().get('CheckCommand')
37+
38+
def set_CheckCommand(self, CheckCommand): # Struct
39+
self.add_body_params("CheckCommand", json.dumps(CheckCommand))
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
#
13+
# Unless required by applicable law or agreed to in writing,
14+
# software distributed under the License is distributed on an
15+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
# KIND, either express or implied. See the License for the
17+
# specific language governing permissions and limitations
18+
# under the License.
19+
20+
from aliyunsdkcore.request import RpcRequest
21+
22+
class CheckProjectHasDependencyRequest(RpcRequest):
23+
24+
def __init__(self):
25+
RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'CheckProjectHasDependency')
26+
self.set_protocol_type('https')
27+
self.set_method('POST')
28+
29+
def get_OpTenantId(self): # Long
30+
return self.get_query_params().get('OpTenantId')
31+
32+
def set_OpTenantId(self, OpTenantId): # Long
33+
self.add_query_param('OpTenantId', OpTenantId)
34+
def get_Id(self): # Long
35+
return self.get_query_params().get('Id')
36+
37+
def set_Id(self, Id): # Long
38+
self.add_query_param('Id', Id)
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
# Licensed to the Apache Software Foundation (ASF) under one
2+
# or more contributor license agreements. See the NOTICE file
3+
# distributed with this work for additional information
4+
# regarding copyright ownership. The ASF licenses this file
5+
# to you under the Apache License, Version 2.0 (the
6+
# "License"); you may not use this file except in compliance
7+
# with the License. You may obtain a copy of the License at
8+
#
9+
#
10+
# http://www.apache.org/licenses/LICENSE-2.0
11+
#
12+
#
13+
# Unless required by applicable law or agreed to in writing,
14+
# software distributed under the License is distributed on an
15+
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16+
# KIND, either express or implied. See the License for the
17+
# specific language governing permissions and limitations
18+
# under the License.
19+
20+
from aliyunsdkcore.request import RpcRequest
21+
import json
22+
23+
class CreateComputeSourceRequest(RpcRequest):
24+
25+
def __init__(self):
26+
RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'CreateComputeSource')
27+
self.set_protocol_type('https')
28+
self.set_method('POST')
29+
30+
def get_OpTenantId(self): # Long
31+
return self.get_query_params().get('OpTenantId')
32+
33+
def set_OpTenantId(self, OpTenantId): # Long
34+
self.add_query_param('OpTenantId', OpTenantId)
35+
def get_CreateCommand(self): # Struct
36+
return self.get_body_params().get('CreateCommand')
37+
38+
def set_CreateCommand(self, CreateCommand): # Struct
39+
self.add_body_params("CreateCommand", json.dumps(CreateCommand))

0 commit comments

Comments
 (0)