Add api GetStreamJobs .

Author: sdk-team

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

@@ -1,3 +1,6 @@
+2025-06-30 Version: 1.0.8
+- Add api GetStreamJobs .
+
 2025-04-28 Version: 1.0.7
 - Dataphin v5.1.0 openAPI changs log.
 - Add API ListRowPermission.

aliyun-python-sdk-dataphin-public/aliyunsdkdataphin_public/__init__.py

@@ -1 +1 @@
-__version__ = '1.0.7'
+__version__ = '1.0.8'

…t/v20230630/SyncDepartmentUserRequest.py …equest/v20230630/GetStreamJobsRequest.pyaliyun-python-sdk-dataphin-public/aliyunsdkdataphin_public/request/v20230630/SyncDepartmentUserRequest.py renamed to aliyun-python-sdk-dataphin-public/aliyunsdkdataphin_public/request/v20230630/GetStreamJobsRequest.py aliyun-python-sdk-dataphin-public/aliyunsdkdataphin_public/request/v20230630/SyncDepartmentUserRequest.py renamed to aliyun-python-sdk-dataphin-public/aliyunsdkdataphin_public/request/v20230630/GetStreamJobsRequest.py

@@ -18,12 +18,11 @@
 # under the License.
 
 from aliyunsdkcore.request import RpcRequest
-import json
 
-class SyncDepartmentUserRequest(RpcRequest):
+class GetStreamJobsRequest(RpcRequest):
 
 	def __init__(self):
-		RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'SyncDepartmentUser')
+		RpcRequest.__init__(self, 'dataphin-public', '2023-06-30', 'GetStreamJobs')
 		self.set_protocol_type('https')
 		self.set_method('POST')
 
@@ -32,8 +31,13 @@ def get_OpTenantId(self): # Long
 
 	def set_OpTenantId(self, OpTenantId):  # Long
 		self.add_query_param('OpTenantId', OpTenantId)
-	def get_SyncDepartmentUserCommand(self): # Struct
-		return self.get_body_params().get('SyncDepartmentUserCommand')
+	def get_Env(self): # String
+		return self.get_query_params().get('Env')
 
-	def set_SyncDepartmentUserCommand(self, SyncDepartmentUserCommand):  # Struct
-		self.add_body_params("SyncDepartmentUserCommand", json.dumps(SyncDepartmentUserCommand))
+	def set_Env(self, Env):  # String
+		self.add_query_param('Env', Env)
+	def get_ProjectId(self): # Long
+		return self.get_query_params().get('ProjectId')
+
+	def set_ProjectId(self, ProjectId):  # Long
+		self.add_query_param('ProjectId', ProjectId)