サーバーレス x IoT 〜我々はどういった課題に直面してそれをどのように解決したのか〜

AWS Deep Night Part.2の登壇資料です。

Transcript

1. ςЄϝЄϹφ x IoT 뺶౯̸΅Ϳ͚͜͹͵抓氂΁ፗᶎͭͼ ͳ΢ΨͿ΄Ξ͜΁ᥴ䷥ͭ͵΄͡뺶 AWS Deep Night Part.2 2018/04/05 Ӿઊ ଛလ 1
2. ᛔ૩奧Օ • Ӿઊ ଛလ • μ϶φϮϊϐϖ ϯϝαϸίϤϷςЄϠφ᮱ • AWSϊϷϲЄτϴЀίЄκϓμϕ • ςЄϝЄςαϖεЀυϘί • GitHub: knakayama • 奺䵉 • ηЀϤϹςЄϝ΄晁አ3ଙ • AWS 2ଙ 2
3. ψϐτϴЀٖ਻΁ͺ͚ͼ • ᛔړ͢樛Υ͹ͼ͚Ρໜկͽ咲ኞͭ͵抓氂;ͳ΄ᥴ䷥ොဩ΁ͺ͚ͼ扖 ͭΔͯ • ᇙ΁AWS IoT;ςЄϝЄϹφίϤϷξЄτϴЀ΁ϢζЄθφͭͼ͚ Δͯ • IoTϔϝαφ΄ϜЄϖγδίΞΠ΀ٖ਻΅扖ͭΔͱΩ̵;͚͜͡ͽ ͣ΀͚ ! • 揾ාل樄ͭΔͯ 3
4. ίυδЀύ 1. Ϳ͚͜͹͵ದ悬Ψֵ͹ͼ͚Ρ΄͡ 2. ίϤϷ͡ΟIoTϔϝαφ΄඙֢΁०䤂ͯΡ㺔氂 3. ᭗Ꭳͭ͵͚樌ᵍ͢Ͱ΢Ρ㺔氂 4. AWS IoT΄ϓφϕͿͯ͜Ρ͡㺔氂 4
5. ίυδЀύ 1. Ϳ͚͜͹͵ದ悬Ψֵ͹ͼ͚Ρ΄͡ 2. ίϤϷ͡ΟIoTϔϝαφ΄඙֢΁०䤂ͯΡ㺔氂 3. ᭗Ꭳͭ͵͚樌ᵍ͢Ͱ΢Ρ㺔氂 4. AWS IoT΄ϓφϕͿͯ͜Ρ͡㺔氂 5
6. ίЄκϓμώϰ༷ᥝ • ᓕቘᘏአϧЄυ΅CloudFront + S3ͽSPA̵ εЀϖϳЄσ΅ϯϝαϸίϤϷ • ϝϐμεЀϖAPI΅API Gateway + Lambda + DynamoDB • Cognito + API Gateway΄θφόϭηЄϊ϶ ασΨڥአͭ͵扯戣/扯ݢ • IoTϔϝαφ΅AWS IoT΁ϔЄόΨPublish̵ Device Shadow奺ኧͽϔϝαφΨ඙֢ • Kinesis Data Streams + LambdaΨڥአͭͼ S3΁ړຉአϔЄόכਂ 6
7. Θ͜੝ͭͪ奧ՕͯΡ; • Lambda樛හ΄϶Ѐόαϭ΅Python • 䯤౮ᓕቘ΅CloudFormation/AWS SAM • CI/CD΁CircleCIΨڥአͭͼ͚Ρ1 • Lambda樛හ΄Ϻνᓕቘ΅Logentries2 • ϮϕϷμφ΅Datadogͽ哶憙 2 https://dev.classmethod.jp/devops/managing-logentries-token-with-terraform-and-ssm-parameter-store/ 1 https://dev.classmethod.jp/server-side/serverless/practical-ci-cd-with-aws-sam-circleci-and-localstack/ 7
8. ίυδЀύ 1. Ϳ͚͜͹͵ದ悬Ψֵ͹ͼ͚Ρ΄͡ 2. ίϤϷ͡ΟIoTϔϝαφ΄඙֢΁०䤂ͯΡ㺔氂 3. ᭗Ꭳͭ͵͚樌ᵍ͢Ͱ΢Ρ㺔氂 4. AWS IoT΄ϓφϕͿͯ͜Ρ͡㺔氂 8
9. Device Shadow;΅ "ϔϝαφ΄匍ࣁ΄ᇫ䙪ఘ䁭΄כਂ;ݐ஑΁ ֵአͫ΢ΡJSONϖκϲϮЀϕͽ̶ͯ"3 "AWS μ϶γϖͽ΄ϔϝαφ΄࿞姆ᤒ匍Ψݢᚆ΁ͭΔ̶ͯๅෛͫ΢͵ᇫ䙪 ఘ䁭Ψϔϝαφτϰϖγ΁ϞϣϷϐτϲͭͼͥ͠;̵ϔϝαφ΅ള姆䦒 ΁ᛔΟ΄ᇫ䙪Ψݶ๗ͫͱΡͩ;͢ͽͣΔ̶ͯΔ͵̵ϔϝαφ΅匍ࣁ΄ᇫ 䙪ΨίϤϷξЄτϴЀΚ㳨΄ϔϝαφአ΁τϰϖγ΁ϞϣϷϐτϲͯΡ ͩ;ΘͽͣΔ̶ͯ"3 3 https://docs.aws.amazon.com/ja_jp/iot/latest/developerguide/what-is-aws-iot.html 9
10. ΀ΡΑͿ뺶 10
11. ᥝͯΡ΁ • AWS IoTӤ΁ਂࣁͯΡ 㫪మጱ΀ ϔϝαφ • ϳЄσ憙ᅩ͡Ο憎Ρ;ͩ΄ϔϝαφ΅㶨΀ΡJSON • ίϤϷ - IoTϔϝαφ樌΄᭗מ΅Device ShadowΨլՕͭͼᤈ͜ • Ӟᛱጱ΁IoTϔϝαφ - Device Shadow樌΅MQTT over TLS̵ί ϤϷ - Device Shadow樌΅HTTPS 11
12. 匍ࣁ΄ᇫ䙪Ψᭆמ • IoTϔϝαφ͢匍ࣁ΄ᇫ䙪( reported )Ψ ᭆמ • ֺ͞ΆՔ΅櫮რ͢ͺ͚ͼ΀͚ • ϕϡϐμ: $aws/things/<thingName>/ shadow/update { "reported": { "power": "off" } } 12
13. ͘ΡΏͣᇫ䙪Ψᭆמ • ίϤϷ͡Ο͘ΡΏͣᇫ䙪( desired )Ψᭆ מ • ֺ͞Ά櫮რͺͧͼѺ • API: UpdateThingShadow { "reported": { "power": "off" }, "desired": { "power": "on" } } 13
14. ͘ΡΏͣᇫ䙪΁ݶ๗ • IoTϔϝαφ͢匍ࣁ΄ᇫ䙪;͘ΡΏͣᇫ䙪΄૧ړ ( delta )ΨݑͧݐΠ̵͘ΡΏͣᇫ䙪(櫮რͺͧΡ)΁ݶ ๗ • ϕϡϐμ: $aws/things/<thingName>/shadow/update/ delta { "reported": { "power": "off" }, "desired": { "power": "on" }, "delta": { "power": "on" } } 14
15. Θ͜੝ͭ奞͚ͥ͜͡; • ͘ΡΏͣᇫ䙪( desired );匍ࣁ΄ᇫ䙪( reported )ΨJSON୵ୗͽכਂ̵ͭͳ΢΁ ૧ړ( delta )͢ਂࣁͭ͵䁰ݳ̵IoTϔϝαφ͘͢ΡΏͣᇫ䙪΁ݶ๗ݢᚆ • IoTϔϝαφ΅MQTTϕϡϐμΎϮϐψЄυΨPublishͭͼDevice Shadow΁ reported Ψᭆמ • ᭋ΁ϕϡϐμΨSubscribeͯΡͩ;ͽ delta ΨݑͧݐΠ̵ desired ΄ᇫ䙪΁ݶ๗ • Device ShadowΨ඙֢ͯΡϕϡϐμ΅AWS IoTͽԪڹ΁䷥Δ͹ͼ͚Ρ • AWS IoT΅ϮϐψЄυΨᓕቘͯΡ(ϮϐψЄυϣϺЄθЄ)Ͷͧ΀΄ͽ̵ϔϝα φ㯎΁ݶ๗ͯΡ͵Η΄䋚ᤰ͢஠ᥝ 15
16. ๋ṛͽͯ΃ 16
17. ͽ̵͚ͺΘ΄Ξ͜΁Device Shadow Ψֵ͹ͼ͚Ρ; 17
18. "An error occurred (ConflictException) when calling the UpdateThingShadow operation: Version conflict" 18
19. ֜᩸ͣ͢͵΄͡ • Device Shadow΁΅ݘ͚ desired ͽӤ䨗ͣͭ΀͚Ξ͜΁Ϻϐμ䱛䯤͢ਂࣁͯ Ρ • Device ShadowΨๅෛͯΡ͵Ή΁αЀμϷϮЀϕͫ΢ΡϝЄυϴЀ΁ΞΡ Ϻϐμ • Device Shadow΄ๅෛ͢ݶ䦒΁咲ኞͭ͵͵Η Version conflict ε϶Є͢咲 ኞͭ͵ • ͺΔΠ̵IoTϔϝαφ΁ΞΡ毱ᔺ΀Device Shadow΄ๅෛ΁Ξ͹ͼ̵ίϤϷ ΁ΞΡUpdateThingShadow͢०䤂ͭΚ͚ͯᇫ䙪΁΀͹ͼ͚͵ 19
20. Ϳ͜ᥴ䷥ͭ͵΄͡ • ϯϝαϸίϤϷͽ಩ൎͭͼͣ͠͵͚ϔЄό;ͳ ͜ͽ΀͚Θ΄ͽPublishͯΡϕϡϐμΨړ櫝ͭ͵ • ಩ൎͭͼͣ͠͵͚ϔЄό: εЀϖϳЄσ΁憎ͱ ͵͚ϔЄό(櫮რ/Ⴥଶ΀Ϳ) • ͳ͜ͽ΀͚ϔЄό: 㶨΀ΡϔЄόړຉአ΄ϔЄ ό • ͳ͜ͽ΀͚ϔЄό΅Device Shadowአϕϡϐμͽ ΅΀̵ͥ㳨΄ϕϡϐμ΁PublishͯΡΞ͜΁䄜ๅ • ֺ: my/things/<thingName>/state • ͺΔΠ̵ӧᥝ΀Device Shadow΄ๅෛΨಪګͭ͵ 20
21. ර懺 • Device Shadow΁ᭆΡΏͣϔЄό΅ίϤϷ͢಩ൎͭͼͥ͠Ώͣ Θ΄͡嘦扯ͭΞ͜ • 㶨奈΁ϔϝαφ΄ϔЄόΨᭆΡͶͧͽ͘΢ΆDevice Shadow; ΅吖΀ΡϕϡϐμͽԪ᪃ΠΡ • AWS IoT΄ϮϐψЄυϣϺЄθЄ΁Ξ͹ͼձ఺΄ϕϡϐμͽ Publish/Subscribeݢᚆ 21
22. ίυδЀύ 1. Ϳ͚͜͹͵ದ悬Ψֵ͹ͼ͚Ρ΄͡ 2. ίϤϷ͡ΟIoTϔϝαφ΄඙֢΁०䤂ͯΡ㺔氂 3. ᭗Ꭳͭ͵͚樌ᵍ͢Ͱ΢Ρ㺔氂 ! 4. AWS IoT΄ϓφϕͿͯ͜Ρ͡㺔氂 22
23. Ϳ͚͜͹͵抓氂͢ਂࣁͭ͵΄͡ • ͘Ρ๵կΨ伋͵ͭ͵䁰ݳ̵ͳ΄๵կΨ伋͵ͭͼ͡Οᇙਧ΄樌ᵍ䶅΁᭗Ꭳͫͱ͵ ͡͹͵ • ٍ֛ጱ΁͚͜;̵IoTϔϝαφ΁吖ଉ͢咲ኞͭ͵ΟϷϫαЀϖ᭗ᎣΨͯΡ;͚͜ Θ΄ • ֺ͞Ά̵吖ଉ咲ኞ஍5ړ䶅΁ϳЄσΎϷϫЀϖ᭗ᎣͯΡ • 吖ଉϔЄό΄ᇫ䙪ᓕቘ΁DynamoDBΨڥአͭͼ͚Ρ • ϷϫαЀϖ᭗Ꭳ΁Ξ͹ͼϳЄσ͢吖ଉΨᥴၾͯΡΔͽ೰ਧࢧහΔͽ媗Πᬬͭ᭗ Ꭳͭ姆ͧΡ஠ᥝ͘Π 23
24. 吖ଉϔЄό͢DynamoDB΁੺ͥΔͽ SELECT *, topic(3) as deviceId FROM '$aws/things/+/shadow/update' WHERE state.reported.someIllegalState = True 24
25. ୮䦒΄ᔰ๠΀ίЄκϓμώϰ 25
26. CloudWatch Events΄φξυϲЄϸΨڥአͭ ͵ϷϫαЀϖ᭗Ꭳ 26
27. 抓氂 • CloudWatch Events΅吖ଉ͢咲ኞͭ͵͡Ϳ͜͡಩ൎͽͣ΀͚ • ͳ΄͵Η̵ଉ΁ᇙਧ΄樌ᵍ䶅΁Lambda樛හΨ᩸㵕ͫͱͼͭΔ ͜ • ͺΔΠ̵僻洏΀抓ᰂ͢咲ኞͯΡ • Δ͵̵ 吖ଉ͢咲ኞͭͼ͡Οᇙਧ樌ᵍ䶅 ΁᭗Ꭳ͢ͽͣ΀͚ 27
28. ϷϫαЀϖ᭗Ꭳ͢Ͱ΢ΡϞόЄЀ 28
29. Ϳ͜ᥴ䷥ͭ͵΄͡ 29
30. DynamoDB Streams + Step Functions 30
31. ίЄκϓμώϰ • 吖ଉᓕቘϓЄϣϸ΁ϔЄό͢PutItemͫ ΢͵ΟDynamoDB StreamsͽLambda樛 හΨ᩸㵕 • ͳ΄Lambda樛හ͢Step FunctionsΨ᩸㵕 • ๋ڡ΁5ړ樌Wait஍̵ϷϫαЀϖڣਧ Lambda樛හΨ᩸㵕ͭ᭗ᎣͯΏͣ͡ڣਧ • ᭗ᎣͯΏͣ䁰ݳ΅εЀϖϳЄσ΁Ϸϫα Ѐϖ • ͩ΢Ψ೰ਧࢧහ媗Πᬬͯ 31
32. ϸЄϤࢧහ΄ڡ๗戔ਧ ... "States": { "ConfigureRemindCount": { "Type": "Pass", "Result": { "count": 5, "index": 0, "step": 1 }, "ResultPath": "$.iterator", "Next": "WaitAMinutes" }, "WaitAMinutes": { "Type": "Wait", "Seconds": 300, "Next": "RemindIterator" }, 32
33. ೰ਧ䦒樌Wait ... "States": { "ConfigureRemindCount": { "Type": "Pass", "Result": { "count": 5, "index": 0, "step": 1 }, "ResultPath": "$.iterator", "Next": "WaitAMinutes" }, "WaitAMinutes": { "Type": "Wait", "Seconds": 300, "Next": "RemindIterator" }, 33
34. ϷϫαЀϖ΄ڣਧ ... "RemindIterator": { "Type": "Task", "Resource": "<_LAMBDA_ARN_>", "ResultPath": "$.iterator", "Next": "IsRemindCountReached" }, "IsRemindCountReached": { "Type": "Choice", "Choices": [ { "Variable": "$.iterator.continue", "BooleanEquals": true, "Next": "Remind" } ], "Default": "Done" }, 34
35. ϷϫαЀϖڣਧ΄πЄϖ ... def handler(event, context): iterator = event['iterator'] dynamodb = boto3.resource('dynamodb').Table(os.environ['TABLE_NAME']) result = dynamodb.get_item(Key={'yourKey': event['yourValue']}) if not result.get('Item'): return {'continue': False} if iterator['index'] <= iterator['count']: continue_ = True else: continue_ = False return { 'index': iterator['index'] + iterator['step'], 'step': iterator['step'], 'count': iteratoro['count'], 'continue': continue_ } 35
36. ϸЄϤΨ姅姆ͯΡ͡ڣਧ ... "RemindIterator": { "Type": "Task", "Resource": "<_LAMBDA_ARN_>", "ResultPath": "$.iterator", "Next": "IsRemindCountReached" }, "IsRemindCountReached": { "Type": "Choice", "Choices": [ { "Variable": "$.iterator.continue", "BooleanEquals": true, "Next": "Remind" } ], "Default": "Done" }, 36
37. ϷϫαЀϖ᭗Ꭳ ... "Remind": { "Type": "Task", "Resource": "<_LAMBDA_ARN_>", "Next": "WaitAMinutes" }, "Done": { "Type": "Pass", "End": true } } } 37
38. ϸЄϤ΄奰ԧ ... "Remind": { "Type": "Task", "Resource": "<_LAMBDA_ARN_>", "Next": "WaitAMinutes" }, "Done": { "Type": "Pass", "End": true } } } 38
39. ίυδЀύ 1. Ϳ͚͜͹͵ದ悬Ψֵ͹ͼ͚Ρ΄͡ 2. ίϤϷ͡ΟIoTϔϝαφ΄඙֢΁०䤂ͯΡ㺔氂 3. ᭗Ꭳͭ͵͚樌ᵍ͢Ͱ΢Ρ㺔氂 4. AWS IoT΄ϓφϕͿͯ͜Ρ͡㺔氂 39
40. 抓氂 • AWS IoT΄ഄΡᛩ͚Ψϓφϕͭ͵͚ • ͽΘͿ͜䨗ͥ΄͚͚͢΄͡ړ͡ΟΩ • ͩ΄͘͵Π΄ఘ䁭΅͘ΔΠ੝΀͚Ҙ • ಋറΠͽ͢ΩΆΡφόαϸ " 40
41. Ք΅ͩΩ΀ఽͮͽϓφϕ䨗͚ͼΔͯ 41
42. ϓφϕ΁ڥአͭͼ͚ΡϯυϲЄϸ • ϓφϕϢϹЄϭϼЄμ: pytest5 • 䰤伛΄unittestϯυϲЄϸΞΠṛ䱛ᚆ͹Γ͚΄ͽ • AWS IoT΄ϯϐμ: moto4 • E2E: AWS IoT Device SDK for Python6 • paho7ΞΠು᨝۸ͫ΢ͼ͚ͼֵ͚Κͯ͡͹͵ 7 http://www.eclipse.org/paho/ 6 https://github.com/aws/aws-iot-device-sdk-python 4 https://github.com/spulec/moto 5 https://github.com/pytest-dev/pytest 42
43. ϳϘϐϕϓφϕ 43
44. ϳϘϐϕϓφϕ΄䜐ኼ • motoΨڥአͭͼBoto3΄IoT8/IoTDataPlane9Ψϯϐμ۸ • pytest΄ conftest.py ͽfixutreΨਧ嬝ͭͼͥ͠ • ݱ圵ϓφϕξЄφͽfixtureΨ޷Ήڊͭͼϓφϕ๵կΨ戔ਧͯΡ • ϓφϕξЄφΨϞ϶ϮЄό۸ͭͼτЀϤϸ΀懿ᬿͽϓφϕθϝ ϹϐυΨṛΗΡ 9 http://boto3.readthedocs.io/en/latest/reference/services/iot-data.html 8 http://boto3.readthedocs.io/en/latest/reference/services/iot.html 44
45. ϓφϕ䌏᨝΄Ϯϊϐϖ • ᇙਧ΄Thing͢ਂࣁͯΡ͡ڣਧͭͼ͚ΡͶͧ class IoTHandler(object): ... def _does_thing_exist(self, thing_name): response = self.iot.describe_thing(thingName=thing_name) if thing_name == response.get('thingName'): return True else: return False 45
46. ϳϘϐϕϓφϕ΄πЄϖ class TestDoesThingExist(object): @pytest.mark.usefixtures('create_thing') @pytest.mark.parametrize( 'thing_name, expected', [ ('my_thing_01', True), ('my_thing_02', False) ]) def test_some_things_exist(self, thing_name, expected): actual = IoTHandler()._does_thing_exist(thing_name) assert actual is expected 46
47. ϓφϕ䌏᨝΄Ϯϊϐϖ • Boto3΄ഄΡᛩ͚Ψϯϐμͫͱ͵͚ • Δ͵̵Thingͯ͢ͽ΁ਂࣁͭͼ͚Ρᇫ丆Ψ֢Π͵͚ class IoTHandler(object): ... def _does_thing_exist(self, thing_name): response = self.iot.describe_thing(thingName=thing_name) if thing_name == response.get('thingName'): return True else: return False 47
48. ϳϘϐϕϓφϕ΄πЄϖ • ϓφϕͭ͵͚ڹ൉๵կ(Thingͯ͢ͽ΁ਂࣁͭͼ͚Ρ)Ψෆ͞Ρ class TestDoesThingExist(object): @pytest.mark.usefixtures('create_thing') @pytest.mark.parametrize( 'thing_name, expected', [ ('my_thing_01', True), ('my_thing_02', False) ]) def test_some_things_exist(self, thing_name, expected): actual = IoTHandler()._does_thing_exist(thing_name) assert actual is expected 48
49. ThingΨԪڹ΁֢౮( conftest.py ) from moto import mock_iot @pytest.fixture(scope='function') def create_thing(request): mock = mock_iot() mock.start() iot = boto3.client('iot') iot.create_thing(thingName='my_thing_01') request.addfinalizer(lambda: mock.stop()) 49
50. ϓφϕ䌏᨝΄Ϯϊϐϖ • Thing͢ਂࣁͯΡ͡ڣਧͯΡړઓΨϓφϕͭ͵͚ class IoTHandler(object): ... def _does_thing_exist(self, thing_name): response = self.iot.describe_thing(thingName=thing_name) if thing_name == response.get('thingName'): return True else: return False 50
51. ϳϘϐϕϓφϕ • ϓφϕͭ͵͚ξЄφΨϞ϶ϮЄό۸ class TestDoesThingExist(object): @pytest.mark.usefixtures('create_thing') @pytest.mark.parametrize( 'thing_name, expected', [ ('my_thing_01', True), ('my_thing_02', False) ]) def test_some_things_exist(self, thing_name, expected): actual = IoTHandler()._does_thing_exist(thing_name) assert actual is expected 51
52. ϳϘϐϕϓφϕ΄πЄϖ • 奾ຎΨϓφϕ class TestDoesThingExist(object): @pytest.mark.usefixtures('create_thing') @pytest.mark.parametrize( 'thing_name, expected', [ ('my_thing_01', True), ('my_thing_02', False) ]) def test_some_things_exist(self, thing_name, expected): actual = IoTHandler()._does_thing_exist(thing_name) assert actual is expected 52
53. E2Eϓφϕ 53
54. E2Eϓφϕ΄᯿ᥝ௔ • ᇙ΁ςЄϝЄϹφίϤϷξЄτϴЀͽ ΅E2Eϓφϕ΅᯿ᥝ10 • ϡόρ϶φαϐώ΁΀Π͢ͷ΀΄ͽ̵ ݱ圵AWSϷϊЄφ͢ྋͭͥ昧൭ͭͼ͚ Ρ͡ϓφϕͭͼͥ͠஠ᥝ͘͢Ρ • ϓφϕ΄ϢΰЄϖϝϐμ͢ग़੝昼ͥ ΀͹ͼΘΚΡ㭅㮔΅͘Ρ 10 https://www.slideshare.net/theburningmonk/serverless-in-production- an-experience-report-jeffconf-88207165/78 54
55. E2Eϓφϕ΄䜐ኼ • ϳϘϐϕϓφϕ(;͚͜͡moto)ͽ΅䌏䖕ͽͣ΀͚塅㾨Ψϓφϕ ͯΡ • AWS IoT΁樛ͭͼ͚͜;AWS IoT Rule Engine΄ഄΡᛩ͚ • fixtureͽAWS IoT Device SDK for PythonΨ̵ֵ͚ϮϐψЄυΨ Publishͫͱͼͥ͠ • 奾ຎΨώδϐμͭͼϓφϕ 55
56. ϓφϕͭ͵͚AWSϷϊЄφ • DynamoDB΁吖ଉϔЄό͢PutItemͫ΢Ρͩ;Ψ嘦扯ͭ͵͚ 56
57. ϓφϕොဩ 57
58. ϮϐψЄυ΄Publish @pytest.mark.parametrize( 'publish_message', [ (({ 'state': { 'reported': { 'someIllegalState': True } } },)) ], indirect=True) def test_some_illegal_states_occured(publish_message): ... SELECT *, topic(3) as device_id FROM '$aws/things/+/shadow/update' WHERE state.reported.someIllegalState = True 58
59. conftest.py @pytest.fixture(scope='function') def publish_message(request): for message in request.param: publish2topic(iot_endpoint='_IOT_ENDPOINT_', topic=f'$aws/things/{my_thing}/shadow/update', message=message, iot_credentials='_IOT_CREDENTIALS_') time.sleep(10) def publish2topic(iot_endpoint, topic, message, iot_credentials): mqtt = AWSIoTMQTTClient('api-test') mqtt.configureEndpoint(iot_endpoint, 8883) mqtt.configureCredentials(iot_credentials['root_ca'], iot_credentials['private_key'], iot_credentials['certificate']) mqtt.connect() mqtt.publish(topic, json.dumps(message), 1) 59
60. Δ;Η • ͚ͥͺ͡΄抓氂;ᥴ䷥ොဩΨͪ奧Օ • ΔͶΔͶද࠺΄֟ࣈ΅͘Πͳ͜ • ୚ͣ姆ͣ毇䔴͹ͼ͚ͥφόαϸ 60