Skip to content

Commit

Permalink
BatchPub Support MQTT5.
Browse files Browse the repository at this point in the history
  • Loading branch information
sdk-team committed Jan 15, 2024
1 parent 3b3d819 commit 494139d
Show file tree
Hide file tree
Showing 426 changed files with 1,195 additions and 426 deletions.
3 changes: 3 additions & 0 deletions aliyun-python-sdk-iot/ChangeLog.txt
Original file line number Diff line number Diff line change
@@ -1,3 +1,6 @@
2024-01-15 Version: 8.58.0
- BatchPub Support MQTT5.

2023-09-25 Version: 8.57.0
- Add Api ResetDeviceTimeline.

Expand Down
2 changes: 1 addition & 1 deletion aliyun-python-sdk-iot/aliyunsdkiot/__init__.py
Original file line number Diff line number Diff line change
@@ -1 +1 @@
__version__ = '8.57.0'
__version__ = '8.58.0'
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class AddDataForApiSourceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AddDataForApiSource')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AddDataForApiSource','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class AddDeviceToSharePromotionRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AddDeviceToSharePromotion')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AddDeviceToSharePromotion','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
#
# http://www.apache.org/licenses/LICENSE-2.0
#
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.

from aliyunsdkcore.request import RpcRequest
from aliyunsdkiot.endpoint import endpoint_data

class AddPowerStationRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AddPowerStation','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
if hasattr(self, "endpoint_regional"):
setattr(self, "endpoint_regional", endpoint_data.getEndpointRegional())


def get_RatedPower(self):
return self.get_query_params().get('RatedPower')

def set_RatedPower(self,RatedPower):
self.add_query_param('RatedPower',RatedPower)

def get_Description(self):
return self.get_query_params().get('Description')

def set_Description(self,Description):
self.add_query_param('Description',Description)

def get_IotInstanceId(self):
return self.get_query_params().get('IotInstanceId')

def set_IotInstanceId(self,IotInstanceId):
self.add_query_param('IotInstanceId',IotInstanceId)

def get_AlgorithmInstanceUid(self):
return self.get_query_params().get('AlgorithmInstanceUid')

def set_AlgorithmInstanceUid(self,AlgorithmInstanceUid):
self.add_query_param('AlgorithmInstanceUid',AlgorithmInstanceUid)

def get_PowerStationName(self):
return self.get_query_params().get('PowerStationName')

def set_PowerStationName(self,PowerStationName):
self.add_query_param('PowerStationName',PowerStationName)
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class AddShareTaskDeviceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AddShareTaskDevice')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AddShareTaskDevice','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class AsyncRRpcRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AsyncRRpc')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AsyncRRpc','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class AttachDestinationRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AttachDestination')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AttachDestination','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class AttachParserDataSourceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AttachParserDataSource')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'AttachParserDataSource','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchAddDataForApiSourceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchAddDataForApiSource')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchAddDataForApiSource','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchAddDeviceGroupRelationsRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchAddDeviceGroupRelations')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchAddDeviceGroupRelations','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchAddThingTopoRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchAddThingTopo')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchAddThingTopo','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchBindDeviceToEdgeInstanceWithDriverRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchBindDeviceToEdgeInstanceWithDriver')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchBindDeviceToEdgeInstanceWithDriver','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchBindDevicesIntoProjectRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchBindDevicesIntoProject')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchBindDevicesIntoProject','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchBindProductsIntoProjectRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchBindProductsIntoProject')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchBindProductsIntoProject','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchCheckDeviceNamesRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCheckDeviceNames')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCheckDeviceNames','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchCheckImportDeviceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCheckImportDevice')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCheckImportDevice','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchCheckVehicleDeviceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCheckVehicleDevice')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCheckVehicleDevice','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand All @@ -48,6 +48,8 @@ def get_DeviceLists(self):

def set_DeviceLists(self, DeviceLists):
for depth1 in range(len(DeviceLists)):
if DeviceLists[depth1].get('DeviceSecret') is not None:
self.add_body_params('DeviceList.' + str(depth1 + 1) + '.DeviceSecret', DeviceLists[depth1].get('DeviceSecret'))
if DeviceLists[depth1].get('DeviceName') is not None:
self.add_body_params('DeviceList.' + str(depth1 + 1) + '.DeviceName', DeviceLists[depth1].get('DeviceName'))
if DeviceLists[depth1].get('DeviceId') is not None:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchClearEdgeInstanceDeviceConfigRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchClearEdgeInstanceDeviceConfig')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchClearEdgeInstanceDeviceConfig','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchCreateSoundCodeLabelRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCreateSoundCodeLabel')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCreateSoundCodeLabel','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchCreateSoundCodeLabelWithLabelsRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCreateSoundCodeLabelWithLabels')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchCreateSoundCodeLabelWithLabels','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchDeleteDeviceGroupRelationsRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchDeleteDeviceGroupRelations')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchDeleteDeviceGroupRelations','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchDeleteEdgeInstanceChannelRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchDeleteEdgeInstanceChannel')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchDeleteEdgeInstanceChannel','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGetDeviceBindStatusRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetDeviceBindStatus')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetDeviceBindStatus','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGetDeviceStateRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetDeviceState')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetDeviceState','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGetEdgeDriverRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeDriver')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeDriver','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGetEdgeInstanceChannelRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceChannel')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceChannel','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGetEdgeInstanceDeviceChannelRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceDeviceChannel')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceDeviceChannel','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGetEdgeInstanceDeviceConfigRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceDeviceConfig')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceDeviceConfig','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGetEdgeInstanceDeviceDriverRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceDeviceDriver')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceDeviceDriver','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGetEdgeInstanceDriverConfigsRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceDriverConfigs')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGetEdgeInstanceDriverConfigs','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchGrayMigrationDeviceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGrayMigrationDevice')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchGrayMigrationDevice','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchImportDeviceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchImportDevice')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchImportDevice','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
class BatchImportVehicleDeviceRequest(RpcRequest):

def __init__(self):
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchImportVehicleDevice')
RpcRequest.__init__(self, 'Iot', '2018-01-20', 'BatchImportVehicleDevice','iot')
self.set_method('POST')
if hasattr(self, "endpoint_map"):
setattr(self, "endpoint_map", endpoint_data.getEndpointMap())
Expand All @@ -48,6 +48,8 @@ def get_DeviceLists(self):

def set_DeviceLists(self, DeviceLists):
for depth1 in range(len(DeviceLists)):
if DeviceLists[depth1].get('DeviceSecret') is not None:
self.add_body_params('DeviceList.' + str(depth1 + 1) + '.DeviceSecret', DeviceLists[depth1].get('DeviceSecret'))
if DeviceLists[depth1].get('DeviceName') is not None:
self.add_body_params('DeviceList.' + str(depth1 + 1) + '.DeviceName', DeviceLists[depth1].get('DeviceName'))
if DeviceLists[depth1].get('DeviceId') is not None:
Expand Down
Loading

0 comments on commit 494139d

Please sign in to comment.