소스 검색

信令通道名增加前缀

locky 1 개월 전
부모
커밋
20f46095e0
2개의 변경된 파일5개의 추가작업 그리고 3개의 파일을 삭제
  1. 4 3
      Controller/AWS/KVSController.py
  2. 1 0
      Object/IOTCore/IotObject.py

+ 4 - 3
Controller/AWS/KVSController.py

@@ -549,7 +549,8 @@ class KVSView(View):
                 'role_alias': 'KvsCameraIoTRoleAlias',
                 'iot_credential_provider_endpoint': iot_credential_provider_endpoint,
             }
-            kvs = KVS.objects.filter(channel_name=serial)
+            channel_name = 'Ansjer_Device_{}'.format(serial)
+            kvs = KVS.objects.filter(channel_name=channel_name)
             if kvs.exists():
                 return response.json(0, res)
 
@@ -558,10 +559,10 @@ class KVSView(View):
                 secret_access_key=SECRET_ACCESS_KEY,
                 region_name=KVS_REGION
             )
-            channel_arn = kinesis_video_obj.create_signaling_channel(channel_name=serial)
+            channel_arn = kinesis_video_obj.create_signaling_channel(channel_name=channel_name)
             now_time = int(time.time())
             KVS.objects.create(
-                channel_name=serial, channel_arn=channel_arn, channel_ttl=60,
+                channel_name=channel_name, channel_arn=channel_arn, channel_ttl=60,
                 created_time=now_time, updated_time=now_time
             )
             return response.json(0, res)

+ 1 - 0
Object/IOTCore/IotObject.py

@@ -145,6 +145,7 @@ class IOTClient:
     def describe_iot_endpoint(self, endpoint_type):
         """
         获取iot endpoint
+        https://docs.amazonaws.cn/en_us/iot/latest/apireference/API_DescribeEndpoint.html
         https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/iot/client/describe_endpoint.html#
         @param endpoint_type: endpoint类型
         @return: