获取证书 同时创建规则

Controller/SerialNumberController.py

@@ -344,7 +344,8 @@ class SerialNumberView(View):
             if uid_serial_qs.exists():
                 uid_serial = uid_serial_qs[0]
 
-                iot = iotdeviceInfoModel.objects.filter(serial_number__serial_number=serial)
+                #iot = iotdeviceInfoModel.objects.filter(serial_number__serial_number=serial)
+                iot = iotdeviceInfoModel.objects.filter(thing_name="Ansjer_Device_" + serial_number)
                 if iot.exists():
                     iot.delete()
 

Object/IOTCore/IotObject.py

@@ -156,24 +156,24 @@ class IOTClient(IOTObject):
                 templateBody=templateBody,
                 parameters=parameters
             )
-
-            # self.client.create_topic_rule(
-            #     ruleName= 'Ansjer_Device_' + serial_number+'_LWT',
-            #     topicRulePayload={
-            #         "sql": 'my/things/'+ 'Ansjer_Device_' + serial_number+'/shadow/update-lwt',
-            #         "ruleDisabled": False,
-            #         "awsIotSqlVersion": "2016-03-23",
-            #         'actions': [
-            #             {
-            #                 'republish': {
-            #                     'roleArn': self.iotrole,
-            #                     'topic': '$$aws/things/'+ 'Ansjer_Device_' + serial_number+'/shadow/update',
-            #                     'qos': 1
-            #                 }
-            #             }
-            #         ]
-            #     }
-            # )
+            topicsql = "SELECT * FROM 'my/things/Ansjer_Device_" + serial_number + "/shadow/update_lwt'"
+            self.client.create_topic_rule(
+                ruleName= 'Ansjer_Device_' + serial_number+'_LWT',
+                topicRulePayload={
+                    "sql": topicsql,
+                    "ruleDisabled": False,
+                    "awsIotSqlVersion": "2016-03-23",
+                    'actions': [
+                        {
+                            'republish': {
+                                'roleArn': self.iotrole,
+                                'topic': '$$aws/things/'+ 'Ansjer_Device_' + serial_number+'/shadow/update',
+                                'qos': 1
+                            }
+                        }
+                    ]
+                }
+            )
             return res, parameters
         except Exception as e:
             print(e)