|
@@ -454,7 +454,8 @@ class CommonService:
|
|
|
print(e)
|
|
|
return False
|
|
|
|
|
|
- def req_publish_mqtt_msg(self, thing_name, topic_name, msg):
|
|
|
+ @staticmethod
|
|
|
+ def req_publish_mqtt_msg(thing_name, topic_name, msg):
|
|
|
# 通用发布MQTT消息函数
|
|
|
if not all([thing_name, topic_name, msg]):
|
|
|
return False
|
|
@@ -474,7 +475,7 @@ class CommonService:
|
|
|
# post请求url发布MQTT消息
|
|
|
url = 'https://{}/topics/{}'.format(endpoint, topic_name)
|
|
|
authorizer_name = 'Ansjer_Iot_Auth'
|
|
|
- signature = self.rsa_sign(Token) # Token签名
|
|
|
+ signature = CommonService.rsa_sign(Token) # Token签名
|
|
|
headers = {
|
|
|
'x-amz-customauthorizer-name': authorizer_name,
|
|
|
'Token': Token,
|