{"id":48348,"date":"2022-11-06T15:52:31","date_gmt":"2023-11-25T16:06:11","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/"},"modified":"2024-04-28T23:22:01","modified_gmt":"2024-04-28T15:22:01","slug":"%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/","title":{"rendered":"\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync"},"content":{"rendered":"

\u9996\u5148<\/h1>\n

\u4f60\u597d\uff0c\u4eca\u5929\u662f2018\u5e74Serverless Advent Calendar\u7684\u7b2c\u5341\u4e5d\u5929\u3002
\n\u8fc7\u53bb\u6211\u53ea\u662f\u89c2\u770b\u8fc7\u8fd9\u4e2aAdvent Calendar\uff0c\u4f46\u662f\u6211\u51b3\u5b9a\u7b2c\u4e00\u6b21\u5199\u4e00\u7bc7\u5173\u4e8e\u6211\u559c\u6b22\u7684Serverless\u7684\u6587\u7ae0\u3002<\/p>\n

\u6211\u548cServerless Advent Calendar 2018<\/h1>\n

\u30fb\u56e0\u4e3a\u6211\u65e2\u7701\u94b1\u53c8\u5bb9\u6613\u538c\u5026\uff0c\u6240\u4ee5\u5bf9\u6309\u91cf\u8ba1\u8d39\u7684\u65e0\u670d\u52a1\u5668(Serverless)\u5f88\u611f\u5174\u8da3
\n\u30fb\u60f3\u8981\u5f00\u53d1\u79fb\u52a8\u5e94\u7528\u7a0b\u5e8f\uff0c\u4f46\u5728\u8ba4\u8bc1\/\u5957\u63a5\u5b57\/\u63a8\u9001\u901a\u77e5\u7b49\u65b9\u9762\u9047\u5230\u4e86\u56f0\u96be
\n\u30fbDynamoDB\u7684\u8bbe\u8ba1\u4e0d\u592a\u7406\u60f3\uff0c\u4e14API\u6570\u91cf\u4e0d\u65ad\u589e\u52a0…(\u5230\u8fd9\u4e00\u70b9\u6211\u5df2\u7ecf\u5931\u53bb\u4e86\u52a8\u529b)
\n\u30fb\u53c2\u52a0\u4e86DevDayTokyo2018\u7684ServerlessDay\u6d3b\u52a8
\n\u30fb\u5728\u5176\u4e2d\u7684\u4e00\u4e2a\u8bb2\u5ea7\u4e2d\u611f\u53d7\u5230\u4e86AWS AppSync\u7684\u4f18\u79c0\u4e4b\u5904\uff0c\u5e76\u786e\u5b9a\u4e86DynamoDB\u7684\u8bbe\u8ba1\u6307\u5357
\n\u30fb\u5728\u6211\u7684\u70ed\u60c5\u6d88\u9000\u4e4b\u524d\u53c2\u52a0\u4e86AdventCalendar\u6d3b\u52a8\uff01<\/p>\n

\u6211\u4e2a\u4eba\u7684\u7ecf\u5386<\/h1>\n

\u30fb\u6709\u774010\u5e74\u7ecf\u9a8c\u7684\u7cfb\u7edf\u5de5\u7a0b\u5e08
\n\u30fb\u5de5\u4f5c\u4e2d\u6ca1\u6709\u4f7f\u7528AWS
\n\u30fb\u5728\u4e1a\u4f59\u65f6\u95f4\u7a0d\u5fae\u6709\u4e00\u4e9bAPIGateway+Lambda+DynamoDB\u7684\u7ecf\u9a8c\uff08\u4f7f\u7528\u4e86SAM\uff09
\n\u30fb\u521d\u6b21\u63a5\u89e6AWS AppSync\uff08\u4e5f\u662f\u521d\u6b21\u63a5\u89e6Cognito\u548cGraphQL\uff09<\/p>\n

\u9a6c\u4e0a\u5f00\u59cb\u6559\u7a0b\u3002<\/h1>\n

\u4e3a\u4e86\u52a0\u6df1\u7406\u89e3\uff0c\u4ee5\u4e0b\u662f\u4e00\u4e2a\u53ef\u884c\u7684\u4e2d\u6587\u7ffb\u8bd1\u9009\u9879\uff1a
\n\u4ee5\u4ee5\u4e0b\u4e3a\u76ee\u6807\uff0c\u201c\u5c3d\u53ef\u80fd\u5730\u201d\u8fdb\u884c\u624b\u52a8\u5236\u4f5c\uff0c\u4ee5\u589e\u8fdb\u7406\u89e3\uff1a
\n\u00b7 \u4f7f\u7528Cognito\u8fdb\u884c\u7528\u6237\u8ba4\u8bc1\uff08\u5305\u62ec\u90ae\u4ef6\u8ba4\u8bc1\u548cGoogle\u5173\u8054\uff09
\n\u00b7 \u901a\u8fc7GraphQL\u8fdb\u884c\u6570\u636e\u8bbf\u95ee\u548c\u66f4\u65b0\uff08\u57fa\u4e8e\u8ba4\u8bc1\u7528\u6237\u7684\u6570\u636e\u8bbf\u95ee\u63a7\u5236\uff09
\n\u00b7 \u5229\u7528GraphQL\u7684\u8ba2\u9605\u529f\u80fd\u8fdb\u884c\u901a\u77e5<\/p>\n

\u6392\u5217<\/h2>\n

\u30fb\u521b\u5efaCognito UserPool\uff08\u9700\u8981\u8bbe\u7f6eAppSync\uff09
\n\u30fb\u5728AppSync\u4e2d\u521b\u5efaAPI
\n\u30fb\u5c1d\u8bd5\u4ece\u7f51\u7ad9\u901a\u8fc7GraphQL\u8fdb\u884c\u6570\u636e\u8bbf\u95ee\u548c\u8ba2\u9605<\/p>\n

\u521b\u5efaCognito UserPool<\/h2>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n

\u8bf7\u8bb0\u4e0b\u4ee5\u4e0b\u5185\u5bb9\uff1a
\n“Pool ID” \u21d2 \u533a\u57df_\u968f\u673a\u5b57\u7b26\u4e32\uff1aus-west-2_xxxxxxxxx
\n“\u5e94\u7528\u7a0b\u5e8f\u5ba2\u6237\u7aefID” \u21d2 \u968f\u673a\u5b57\u7b26\u4e32\uff1axxxxxxxxxxxxxxxxxxxxxxxxxx<\/p>\n

\u4f7f\u7528\u7535\u5b50\u90ae\u4ef6\u8ba4\u8bc1\u521b\u5efa\u7528\u6237<\/h4>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"undefined\"<\/div>\n
\"undefined\"<\/div>\n
\"undefined\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n

\u901a\u8fc7\u4e0e\u8c37\u6b4c\u7684\u5408\u4f5c\u521b\u5efa\u7528\u6237\u3002<\/h4>\n
\"image.png\"<\/div>\n
\"undefined\"<\/div>\n
\"image.png\"<\/div>\n

\u8bf7\u8bbe\u7f6e\u4ee5\u4e0b\u5185\u5bb9\u4f5c\u4e3a\u5df2\u8ba4\u53ef\u7684\u91cd\u5b9a\u5411URI\uff1a
\nhttps:\/\/\u8bbe\u7f6e\u7684\u57df\u540d.auth.\u533a\u57df.amazoncognito.com\/oauth2\/idpresponse<\/p>\n

\"undefined\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n

Appsync \u7684\u914d\u7f6e\u8bbe\u7f6e<\/h2>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n
\"image.png\"<\/div>\n

\u5728\u201c\u8bbe\u7f6e\u201d\u4e2d\u67e5\u770b\u5e76\u8bb0\u5f55\u8bbe\u7f6e\uff0c\u4ee5\u4fbf\u786e\u8ba4AppSync\u5df2\u521b\u5efa
\nAPI URL
\nAPI ID<\/p>\n

\"image.png\"<\/div>\n
\"undefined\"<\/div>\n

\u5c1d\u8bd5\u4ece\u7f51\u7ad9\u4f7f\u7528Cognito\u767b\u5f55\u548cGraphQL\u83b7\u53d6\/\u6ce8\u518c\u6570\u636e\u3002<\/h2>\n

\u8981\u8c03\u7528GraphQL\uff0c\u9700\u8981\u6709jwt\uff08\u8bbf\u95ee\u4ee4\u724c\uff09\u3002
\njwt\u662f\u5728\u6388\u6743\u9875\u9762\u4e0a\u8fdb\u884c\u6388\u6743\u540e\uff0c\u901a\u8fc7\u91cd\u5b9a\u5411URL\u8df3\u8f6c\u65f6\u4f7f\u7528\u67e5\u8be2\u53c2\u6570[code]\uff0c\u53ef\u4ee5\u4ececognito\u7684\u7aef\u70b9\u83b7\u53d6\u3002<\/p>\n

\u4f7f\u7528\u4ee5\u4e0b\u987a\u5e8f\u6765\u89e3\u91ca\u767b\u5f55\u5904\u7406\u7684\u6b65\u9aa4\uff1a
\n– \u52a0\u8f7d\u5916\u90e8JavaScript\u6587\u4ef6
\n– \u81ea\u5b9a\u4e49\u51fd\u6570\u96c6
\n– \u6267\u884c\u767b\u5f55\u5904\u7406<\/p>\n

<<\/span>html<\/span>><\/span>\r\n<<\/span>head<\/span>><\/span>\r\n  <<\/span>meta<\/span> charset<\/span>=<\/span>\"<\/span>UTF-8<\/span>\"<\/span>><\/span>\r\n  <!--<\/span> \u5916\u90e8javascript\u306e\u8aad\u307f\u8fbc\u307f<\/span> --><\/span>\r\n  <<\/span>script<\/span>\r\n  src<\/span>=<\/span>\"<\/span>https:\/\/code.jquery.com\/jquery-3.3.1.min.js<\/span>\"<\/span>\r\n  integrity<\/span>=<\/span>\"<\/span>sha256-FgpCb\/KJQlLNfOu91ta32o\/NMZxltwRo8QtmkMRdAu8=<\/span>\"<\/span>\r\n  crossorigin<\/span>=<\/span>\"<\/span>anonymous<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>  <<\/span>script<\/span> type<\/span>=<\/span>\"<\/span>module<\/span>\"<\/span> src<\/span>=<\/span>\"<\/span>src\/aws-exports.js<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>  <<\/span>script<\/span> src<\/span>=<\/span>\"<\/span>src\/aws-sdk.js<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>  <<\/span>script<\/span> src<\/span>=<\/span>\"<\/span>src\/config.js<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>  <<\/span>script<\/span> src<\/span>=<\/span>\"<\/span>https:\/\/cdnjs.cloudflare.com\/ajax\/libs\/paho-mqtt\/1.0.1\/mqttws31.min.js<\/span>\"<\/span> type<\/span>=<\/span>\"<\/span>text\/javascript<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>\r\n  <!--<\/span> \u72ec\u81ea\u95a2\u6570\u7fa4<\/span> --><\/span>\r\n  <<\/span>script<\/span>><\/span>\r\n    var<\/span> _resolve<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span> return<\/span> $<\/span>.<\/span>Deferred<\/span>().<\/span>resolve<\/span>(<\/span>x<\/span>).<\/span>promise<\/span>();<\/span> };<\/span>\r\n    var<\/span> _reject<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span> return<\/span> $<\/span>.<\/span>Deferred<\/span>().<\/span>reject<\/span>(<\/span>x<\/span>).<\/span>promise<\/span>();<\/span> };<\/span>\r\n    var<\/span> _getStorageItem<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span>\r\n      var<\/span> _item<\/span> =<\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>localStorage<\/span>.<\/span>getItem<\/span>(<\/span>x<\/span>));<\/span>\r\n      return<\/span> _item<\/span> ?<\/span> _item<\/span> :<\/span> {};<\/span>\r\n    };<\/span>\r\n\r\n    _param<\/span>=<\/span>{};<\/span>\r\n    location<\/span>.<\/span>search<\/span>.<\/span>slice<\/span>(<\/span>1<\/span>).<\/span>split<\/span>(<\/span>\"<\/span>&<\/span>\"<\/span>).<\/span>forEach<\/span>(<\/span>v<\/span>=><\/span>{<\/span>\r\n      key<\/span> =<\/span> v<\/span>.<\/span>split<\/span>(<\/span>\"<\/span>=<\/span>\"<\/span>)[<\/span>0<\/span>];<\/span>\r\n      _param<\/span>[<\/span>key<\/span>]<\/span> =<\/span> v<\/span>.<\/span>replace<\/span>(<\/span>key<\/span>+<\/span>\"<\/span>=<\/span>\"<\/span>,<\/span>\"\"<\/span>);<\/span>\r\n    });<\/span>\r\n    var<\/span> _cognito<\/span> =<\/span> {<\/span>\r\n      storage<\/span> :<\/span> {<\/span>\r\n        setTokens<\/span> :<\/span> _tokens<\/span> =><\/span> {<\/span>\r\n          localStorage<\/span>.<\/span>setItem<\/span>(<\/span>\"<\/span>tokens<\/span>\"<\/span>,<\/span> JSON<\/span>.<\/span>stringify<\/span>(<\/span>_tokens<\/span>));<\/span>\r\n          _cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span> =<\/span> _tokens<\/span>.<\/span>access_token<\/span>;<\/span>\r\n          return<\/span> _resolve<\/span>(<\/span>_tokens<\/span>);<\/span>\r\n        },<\/span>\r\n        jwt<\/span> :<\/span> _getStorageItem<\/span>(<\/span>\"<\/span>tokens<\/span>\"<\/span>).<\/span>access_token<\/span>\r\n      },<\/span>\r\n      api<\/span> :<\/span> {<\/span>\r\n        getTokens<\/span> :<\/span> _code<\/span> =><\/span> {<\/span>\r\n          return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n            url<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_tokenEndpoint<\/span>,<\/span>\r\n            method<\/span>:<\/span> \"<\/span>POST<\/span>\"<\/span>,<\/span>\r\n            contentType<\/span>:<\/span> \"<\/span>application\/x-www-form-urlencoded<\/span>\"<\/span>,<\/span>\r\n            data<\/span>:<\/span> {<\/span>\r\n              grant_type<\/span>:<\/span> \"<\/span>authorization_code<\/span>\"<\/span>,<\/span>\r\n              client_id<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_clientid<\/span>,<\/span>\r\n              redirect_uri<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_redirecturl<\/span>,<\/span>\r\n              code<\/span>:<\/span> _code<\/span>,<\/span>\r\n            },<\/span>\r\n          })<\/span>\r\n        },<\/span>\r\n        getUser<\/span> :<\/span> ()<\/span> =><\/span> {<\/span>\r\n          return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n            url<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_userEndpoint<\/span>,<\/span>\r\n            method<\/span>:<\/span> \"<\/span>GET<\/span>\"<\/span>,<\/span>\r\n            contentType<\/span>:<\/span> \"<\/span>application\/json<\/span>\"<\/span>,<\/span>\r\n            headers<\/span>:<\/span> {<\/span>\r\n              Authorization<\/span>:<\/span> \"<\/span>Bearer <\/span>\"<\/span>+<\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>\r\n            },<\/span>\r\n          })<\/span>\r\n        },<\/span>\r\n        graphql<\/span> :<\/span> (<\/span>_query<\/span>)<\/span> =><\/span> {<\/span>\r\n          return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n            url<\/span>:<\/span> opt<\/span>.<\/span>aws_appsync_graphqlEndpoint<\/span>,<\/span>\r\n            method<\/span>:<\/span> \"<\/span>POST<\/span>\"<\/span>,<\/span>\r\n            contentType<\/span>:<\/span> \"<\/span>application\/json<\/span>\"<\/span>,<\/span>\r\n            headers<\/span>:<\/span> {<\/span>\r\n              Authorization<\/span>:<\/span> _cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>\r\n            },<\/span>\r\n            data<\/span>:<\/span> JSON<\/span>.<\/span>stringify<\/span>(<\/span>_query<\/span>),<\/span>\r\n          })<\/span>\r\n        },<\/span>\r\n      },<\/span>\r\n    };<\/span>\r\n\r\n    \/\/\u30ed\u30b0\u30a4\u30f3\u51e6\u7406<\/span>\r\n    typeof<\/span> _cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span> ===<\/span> \"<\/span>undefined<\/span>\"<\/span> &&<\/span> !<\/span>_param<\/span>.<\/span>code<\/span> ?<\/span> location<\/span>.<\/span>href<\/span> =<\/span> opt<\/span>.<\/span>aws_cognito_loginEndpoint<\/span> :<\/span> \"\"<\/span>;<\/span> \/\/token, code\u306a\u3057<\/span>\r\n    (<\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>\r\n      ?<\/span> _resolve<\/span>(<\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>)<\/span>\r\n      :<\/span> _cognito<\/span>.<\/span>api<\/span>.<\/span>getTokens<\/span>(<\/span>_param<\/span>.<\/span>code<\/span>)<\/span> \/\/token\u53d6\u5f97<\/span>\r\n        .<\/span>then<\/span>(<\/span>x<\/span>=><\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>setTokens<\/span>(<\/span>x<\/span>))<\/span> \/\/storage\u306b\u4fdd\u5b58<\/span>\r\n        .<\/span>then<\/span>(<\/span>x<\/span>=><\/span>location<\/span>.<\/span>href<\/span>=<\/span>opt<\/span>.<\/span>aws_cognito_redirecturl<\/span>)<\/span>\r\n    )<\/span>\r\n    .<\/span>then<\/span>(()<\/span> =><\/span>\r\n      _cognito<\/span>.<\/span>api<\/span>.<\/span>graphql<\/span>({<\/span>\r\n        query<\/span>:<\/span> `\r\n          {\r\n            getMyInfo {\r\n              id\r\n              email\r\n            }\r\n          }\r\n        `<\/span>})<\/span>\r\n    )<\/span>\r\n    .<\/span>then<\/span>(<\/span>x<\/span>=><\/span>{<\/span>\r\n      return<\/span> x<\/span>.<\/span>data<\/span>.<\/span>getMyInfo<\/span>\r\n      ?<\/span> _resolve<\/span>(<\/span>console<\/span>.<\/span>log<\/span>(<\/span>x<\/span>.<\/span>data<\/span>.<\/span>getMyInfo<\/span>))<\/span>\r\n      :<\/span> _cognito<\/span>.<\/span>api<\/span>.<\/span>getUser<\/span>()<\/span> \/\/\u30e6\u30fc\u30b6\u60c5\u5831\u53d6\u5f97<\/span>\r\n        .<\/span>then<\/span>(<\/span>x<\/span>=><\/span>_cognito<\/span>.<\/span>api<\/span>.<\/span>graphql<\/span>({<\/span> \/\/\u30e6\u30fc\u30b6\u4f5c\u6210<\/span>\r\n          operationName<\/span>:<\/span> \"<\/span>myInfo<\/span>\"<\/span>,<\/span>\r\n          query<\/span>:<\/span> `\r\n            mutation myInfo($input: CreateMyInfoInput!){\r\n              createMyInfo(input: $input){\r\n                email\r\n              }\r\n            }`<\/span>,<\/span>\r\n          variables<\/span>:<\/span> {<\/span>\r\n            \"<\/span>input<\/span>\"<\/span>:<\/span> {<\/span>\r\n              \"<\/span>email<\/span>\"<\/span>:<\/span> x<\/span>.<\/span>email<\/span>\r\n            }<\/span>\r\n          }<\/span>\r\n        }));<\/span>\r\n    })<\/span>\r\n    .<\/span>fail<\/span>(<\/span>x<\/span>=><\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>setTokens<\/span>({}).<\/span>then<\/span>(<\/span>x<\/span>=><\/span>location<\/span>.<\/span>href<\/span> =<\/span> opt<\/span>.<\/span>aws_cognito_loginEndpoint<\/span>));<\/span>\r\n  <<\/span>\/script<\/span>>\r\n<\/span><<\/span>\/head<\/span>>\r\n<\/span><<\/span>body<\/span>><\/span>\r\n<<\/span>\/body<\/span>>\r\n<\/span><<\/span>\/html<\/span>>\r\n<\/span><\/code><\/pre>\n
\u5916\u90e8JavaScript\u7684\u52a0\u8f7d<\/h3>\n
\u30fb\u4eceCDN\u83b7\u53d6\u7684jQuery
\n\u30fb\u4f7f\u7528amplify\u547d\u4ee4\u521b\u5efa\u7684aws-exports.js
\n\u30fbaws-sdk.js
\n\u30fb\u7528\u4e8e\u5b9a\u4e49\u5e38\u91cf\u7b49\u7684config.js\uff08\u8fd9\u662f\u6211\u4ece\u5934\u5f00\u59cb\u521b\u5efa\u7684js\u6587\u4ef6\uff09
\n\u30fb\u4ecePaho Javascript Client\u4e0b\u8f7d\u7684mqttws31.min.js<\/p>\n
  <!--<\/span> \u5916\u90e8javascript\u306e\u8aad\u307f\u8fbc\u307f<\/span> --><\/span>\r\n  <<\/span>script<\/span>\r\n  src<\/span>=<\/span>\"<\/span>https:\/\/code.jquery.com\/jquery-3.3.1.min.js<\/span>\"<\/span>\r\n  integrity<\/span>=<\/span>\"<\/span>sha256-FgpCb\/KJQlLNfOu91ta32o\/NMZxltwRo8QtmkMRdAu8=<\/span>\"<\/span>\r\n  crossorigin<\/span>=<\/span>\"<\/span>anonymous<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>  <<\/span>script<\/span> type<\/span>=<\/span>\"<\/span>module<\/span>\"<\/span> src<\/span>=<\/span>\"<\/span>src\/aws-exports.js<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>  <<\/span>script<\/span> src<\/span>=<\/span>\"<\/span>src\/aws-sdk.js<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>  <<\/span>script<\/span> src<\/span>=<\/span>\"<\/span>src\/config.js<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span>  <<\/span>script<\/span> src<\/span>=<\/span>\"<\/span>https:\/\/cdnjs.cloudflare.com\/ajax\/libs\/paho-mqtt\/1.0.1\/mqttws31.min.js<\/span>\"<\/span> type<\/span>=<\/span>\"<\/span>text\/javascript<\/span>\"<\/span>><<\/span>\/script<\/span>>\r\n<\/span><\/code><\/pre>\n
\u5355\u72ec\u7684\u51fd\u6570\u96c6\u5408<\/h3>\n
\u30fb\u7528\u4e8ePromise\u7684_resolve\u3001_reject\u51fd\u6570
\n\u30fb\u7528\u4e8e\u8bbf\u95ee\u672c\u5730\u5b58\u50a8\u7684_getStorageItem\u51fd\u6570
\n\u30fb\u7528\u4e8e\u5b58\u50a8\u83b7\u53d6\u5230\u7684Get\u53c2\u6570\u7ed3\u679c\u7684_param\u5bf9\u8c61<\/p>\n
var<\/span> _resolve<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span> return<\/span> $<\/span>.<\/span>Deferred<\/span>().<\/span>resolve<\/span>(<\/span>x<\/span>).<\/span>promise<\/span>();<\/span> };<\/span>\r\nvar<\/span> _reject<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span> return<\/span> $<\/span>.<\/span>Deferred<\/span>().<\/span>reject<\/span>(<\/span>x<\/span>).<\/span>promise<\/span>();<\/span> };<\/span>\r\nvar<\/span> _getStorageItem<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span>\r\n  var<\/span> _item<\/span> =<\/span> JSON<\/span>.<\/span>parse<\/span>(<\/span>localStorage<\/span>.<\/span>getItem<\/span>(<\/span>x<\/span>));<\/span>\r\n  return<\/span> _item<\/span> ?<\/span> _item<\/span> :<\/span> {};<\/span>\r\n};<\/span>\r\n\r\n_param<\/span>=<\/span>{};<\/span>\r\nlocation<\/span>.<\/span>search<\/span>.<\/span>slice<\/span>(<\/span>1<\/span>).<\/span>split<\/span>(<\/span>\"<\/span>&<\/span>\"<\/span>).<\/span>forEach<\/span>(<\/span>v<\/span>=><\/span>{<\/span>\r\n  key<\/span> =<\/span> v<\/span>.<\/span>split<\/span>(<\/span>\"<\/span>=<\/span>\"<\/span>)[<\/span>0<\/span>];<\/span>\r\n  _param<\/span>[<\/span>key<\/span>]<\/span> =<\/span> v<\/span>.<\/span>replace<\/span>(<\/span>key<\/span>+<\/span>\"<\/span>=<\/span>\"<\/span>,<\/span>\"\"<\/span>);<\/span>\r\n});<\/span>\r\n<\/code><\/pre>\n
\u30fb\u7528\u4e8eCognito\/GraphQL\u8bbf\u95ee\u7684_cognito\u5bf9\u8c61<\/p>\n
\n
\u95a2\u6570\u540d\u8aac\u660e_cognito.storage.setTokenscognito\u304b\u3089\u53d6\u5f97\u3057\u305f\u30a2\u30af\u30bb\u30b9\u30c8\u30fc\u30af\u30f3\u3092\u30ed\u30fc\u30ab\u30eb\u30b9\u30c8\u30ec\u30fc\u30b8\u306b\u4fdd\u5b58\u3059\u308b\u95a2\u6570_cognito.storage.jwt\u30a2\u30af\u30bb\u30b9\u30c8\u30fc\u30af\u30f3\u3092\u683c\u7d0d\u3059\u308b\u5909\u6570_cognito.api.getTokenscognito\u304b\u3089\u30a2\u30af\u30bb\u30b9\u30c8\u30fc\u30af\u30f3\u3092\u53d6\u5f97\u3059\u308b\u95a2\u6570_cognito.api.getUsercognito\u304b\u3089\u30ed\u30b0\u30a4\u30f3\u4e2d\u306e\u30e6\u30fc\u30b6\u60c5\u5831\u3092\u53d6\u5f97\u3059\u308b\u95a2\u6570_cognito.api.graphqlAppsync\u306eGraphQL API\u3092\u547c\u3073\u51fa\u3059\u95a2\u6570<\/div>\n<\/div>\n
var<\/span> _cognito<\/span> =<\/span> {<\/span>\r\n  storage<\/span> :<\/span> {<\/span>\r\n    setTokens<\/span> :<\/span> _tokens<\/span> =><\/span> {<\/span>\r\n      localStorage<\/span>.<\/span>setItem<\/span>(<\/span>\"<\/span>tokens<\/span>\"<\/span>,<\/span> JSON<\/span>.<\/span>stringify<\/span>(<\/span>_tokens<\/span>));<\/span>\r\n      _cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span> =<\/span> _tokens<\/span>.<\/span>access_token<\/span>;<\/span>\r\n      return<\/span> _resolve<\/span>(<\/span>_tokens<\/span>);<\/span>\r\n    },<\/span>\r\n    jwt<\/span> :<\/span> _getStorageItem<\/span>(<\/span>\"<\/span>tokens<\/span>\"<\/span>).<\/span>access_token<\/span>\r\n  },<\/span>\r\n  api<\/span> :<\/span> {<\/span>\r\n    getTokens<\/span> :<\/span> _code<\/span> =><\/span> {<\/span>\r\n      return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n        url<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_tokenEndpoint<\/span>,<\/span>\r\n        method<\/span>:<\/span> \"<\/span>POST<\/span>\"<\/span>,<\/span>\r\n        contentType<\/span>:<\/span> \"<\/span>application\/x-www-form-urlencoded<\/span>\"<\/span>,<\/span>\r\n        data<\/span>:<\/span> {<\/span>\r\n          grant_type<\/span>:<\/span> \"<\/span>authorization_code<\/span>\"<\/span>,<\/span>\r\n          client_id<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_clientid<\/span>,<\/span>\r\n          redirect_uri<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_redirecturl<\/span>,<\/span>\r\n          code<\/span>:<\/span> _code<\/span>,<\/span>\r\n        },<\/span>\r\n      })<\/span>\r\n    },<\/span>\r\n    getUser<\/span> :<\/span> ()<\/span> =><\/span> {<\/span>\r\n      return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n        url<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_userEndpoint<\/span>,<\/span>\r\n        method<\/span>:<\/span> \"<\/span>GET<\/span>\"<\/span>,<\/span>\r\n        contentType<\/span>:<\/span> \"<\/span>application\/json<\/span>\"<\/span>,<\/span>\r\n        headers<\/span>:<\/span> {<\/span>\r\n          Authorization<\/span>:<\/span> \"<\/span>Bearer <\/span>\"<\/span>+<\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>\r\n        },<\/span>\r\n      })<\/span>\r\n    },<\/span>\r\n    graphql<\/span> :<\/span> (<\/span>_query<\/span>)<\/span> =><\/span> {<\/span>\r\n      return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n        url<\/span>:<\/span> opt<\/span>.<\/span>aws_appsync_graphqlEndpoint<\/span>,<\/span>\r\n        method<\/span>:<\/span> \"<\/span>POST<\/span>\"<\/span>,<\/span>\r\n        contentType<\/span>:<\/span> \"<\/span>application\/json<\/span>\"<\/span>,<\/span>\r\n        headers<\/span>:<\/span> {<\/span>\r\n          Authorization<\/span>:<\/span> _cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>\r\n        },<\/span>\r\n        data<\/span>:<\/span> JSON<\/span>.<\/span>stringify<\/span>(<\/span>_query<\/span>),<\/span>\r\n      })<\/span>\r\n    },<\/span>\r\n  },<\/span>\r\n};<\/span>\r\n<\/code><\/pre>\n
\u767b\u5f55\u64cd\u4f5c<\/h3>\n
\u5982\u679cJWT\u672a\u5b58\u50a8\u5728\u5b58\u50a8\u4e2d\uff0c\u5e76\u4e14\u53c2\u6570\u4e2d\u6ca1\u6709code\uff0c\u5219\u5c06\u91cd\u5b9a\u5411\u5230\u8ba4\u8bc1\u9875\u9762\u3002<\/p>\n
\/\/\u30ed\u30b0\u30a4\u30f3\u51e6\u7406<\/span>\r\ntypeof<\/span> _cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span> ===<\/span> \"<\/span>undefined<\/span>\"<\/span> &&<\/span> !<\/span>_param<\/span>.<\/span>code<\/span> ?<\/span> location<\/span>.<\/span>href<\/span> =<\/span> opt<\/span>.<\/span>aws_cognito_loginEndpoint<\/span> :<\/span> \"\"<\/span>;<\/span> \/\/token, code\u306a\u3057<\/span>\r\n<\/code><\/pre>\n
1. \u5982\u679c\u672c\u5730\u5b58\u50a8\u4e2d\u5b58\u5728 JWT\uff0c\u5219\u8fdb\u5165\u6b65\u9aa42\uff1b\u5982\u679c\u4e0d\u5b58\u5728 JWT\uff0c\u5219\u4ece Cognito \u83b7\u53d6\u5e76\u4fdd\u5b58\u5230\u672c\u5730\u5b58\u50a8\u3002
\n2. \u83b7\u53d6\u5230 JWT \u540e\uff0c\u4ece GraphQL\uff08DynamoDB\uff09\u4e2d\u83b7\u53d6\u81ea\u5df1\u7684\u4fe1\u606f\u3002
\n3. \u5982\u679c\u6210\u529f\u83b7\u53d6\u5230\u81ea\u5df1\u7684\u4fe1\u606f\uff0c\u5219\u5c06\u5176\u8f93\u51fa\u5230\u63a7\u5236\u53f0\u5e76\u7ed3\u675f\u3002
\n4. \u5982\u679c\u65e0\u6cd5\u83b7\u53d6\u5230\u81ea\u5df1\u7684\u4fe1\u606f\uff0c\u5219\u5728 DynamoDB \u4e2d\u521b\u5efa\u6570\u636e\uff08\u901a\u8fc7\u4ece Cognito \u83b7\u53d6\u7535\u5b50\u90ae\u4ef6\u4fe1\u606f\u5e76\u5728 GraphQL \u4e2d\u6267\u884c\uff09\u3002<\/p>\n
(<\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>\r\n  ?<\/span> _resolve<\/span>(<\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>)<\/span>\r\n  :<\/span> _cognito<\/span>.<\/span>api<\/span>.<\/span>getTokens<\/span>(<\/span>_param<\/span>.<\/span>code<\/span>)<\/span> \/\/1.cognito\u304b\u3089token\u53d6\u5f97<\/span>\r\n    .<\/span>then<\/span>(<\/span>x<\/span>=><\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>setTokens<\/span>(<\/span>x<\/span>))<\/span> \/\/1.storage\u306b\u4fdd\u5b58<\/span>\r\n    .<\/span>then<\/span>(<\/span>x<\/span>=><\/span>location<\/span>.<\/span>href<\/span>=<\/span>opt<\/span>.<\/span>aws_cognito_redirecturl<\/span>)<\/span>\r\n)<\/span>\r\n.<\/span>then<\/span>(()<\/span> =><\/span>\r\n  _cognito<\/span>.<\/span>api<\/span>.<\/span>graphql<\/span>({<\/span> \/\/2.\u81ea\u8eab\u306e\u60c5\u5831\u3092\u53d6\u5f97\u3059\u308b<\/span>\r\n    query<\/span>:<\/span> `\r\n      {\r\n        getMyInfo {\r\n          id\r\n          email\r\n        }\r\n      }\r\n    `<\/span>})<\/span>\r\n)<\/span>\r\n.<\/span>then<\/span>(<\/span>x<\/span>=><\/span>{<\/span>\r\n  return<\/span> x<\/span>.<\/span>data<\/span>.<\/span>getMyInfo<\/span>\r\n  ?<\/span> _resolve<\/span>(<\/span>console<\/span>.<\/span>log<\/span>(<\/span>x<\/span>.<\/span>data<\/span>.<\/span>getMyInfo<\/span>))<\/span> \/\/3. \u30b3\u30f3\u30bd\u30fc\u30eb\u306b\u51fa\u529b\u3057\u3066\u7d42\u4e86<\/span>\r\n  :<\/span> _cognito<\/span>.<\/span>api<\/span>.<\/span>getUser<\/span>()<\/span> \/\/4. cognito\u304b\u3089\u30e6\u30fc\u30b6\u60c5\u5831\u53d6\u5f97<\/span>\r\n    .<\/span>then<\/span>(<\/span>x<\/span>=><\/span>_cognito<\/span>.<\/span>api<\/span>.<\/span>graphql<\/span>({<\/span> \/\/4. GraphQL\u3067\u30e6\u30fc\u30b6\u4f5c\u6210<\/span>\r\n      operationName<\/span>:<\/span> \"<\/span>myInfo<\/span>\"<\/span>,<\/span>\r\n      query<\/span>:<\/span> `\r\n        mutation myInfo($input: CreateMyInfoInput!){\r\n          createMyInfo(input: $input){\r\n            email\r\n          }\r\n        }`<\/span>,<\/span>\r\n      variables<\/span>:<\/span> {<\/span>\r\n        \"<\/span>input<\/span>\"<\/span>:<\/span> {<\/span>\r\n          \"<\/span>email<\/span>\"<\/span>:<\/span> x<\/span>.<\/span>email<\/span> \/\/4. cognito\u304b\u3089\u53d6\u5f97\u3057\u305f\u30e6\u30fc\u30b6\u60c5\u5831\u306eemail\u3092\u5229\u7528\u3059\u308b<\/span>\r\n        }<\/span>\r\n      }<\/span>\r\n    }));<\/span>\r\n})<\/span>\r\n.<\/span>fail<\/span>(<\/span>x<\/span>=><\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>setTokens<\/span>({}).<\/span>then<\/span>(<\/span>x<\/span>=><\/span>location<\/span>.<\/span>href<\/span> =<\/span> opt<\/span>.<\/span>aws_cognito_loginEndpoint<\/span>));<\/span> \/\/\u30a8\u30e9\u30fc\u6642\u306ftoken\u3092\u5168\u3066\u6d88\u3057\u3066\u30ea\u30c0\u30a4\u30ec\u30af\u30c8\u3059\u308b\uff08\u6700\u521d\u304b\u3089\u3084\u308a\u76f4\u3057\uff09<\/span>\r\n<\/code><\/pre>\n
\u53d6\u5f97\u201cgetMyInfo\u201d\u7684\u89e3\u6790\u5668\u5982\u4e0b\uff1a
\n\u4f7f\u7528Cognito\u7684sub\u4f5c\u4e3aID\u3002<\/p>\n
#request mapping template\r\n{\r\n    \"version\": \"2017-02-28\",\r\n    \"operation\": \"GetItem\",\r\n    \"key\": {\r\n        \"id\": { \"S\" : \"${context.identity.sub}\" }\r\n    }\r\n}\r\n#response mapping template\r\n$util.toJson($ctx.result)\r\n<\/code><\/pre>\n
\u4ee5\u4e0b\u662f`createMyInfo`\u7684\u89e3\u6790\u5668\uff1a
\n\u4f7f\u7528cognito\u7684sub\u4f5c\u4e3aID\u3002
\n\u5728attributeValues\u4e2d\u8bbe\u7f6einput\u7684email\u3002<\/p>\n
#request mapping template\r\n{\r\n  \"version\": \"2017-02-28\",\r\n  \"operation\": \"PutItem\",\r\n  \"key\": {\r\n    \"id\": $util.dynamodb.toDynamoDBJson($ctx.identity.sub),\r\n  },\r\n  \"attributeValues\": $util.dynamodb.toMapValuesJson($ctx.args.input),\r\n  \"condition\": {\r\n    \"expression\": \"attribute_not_exists(#id)\",\r\n    \"expressionNames\": {\r\n      \"#id\": \"id\",\r\n    },\r\n  },\r\n}\r\n#response mapping template\r\n$util.toJson($ctx.result)\r\n<\/code><\/pre>\n
\u6211\u7ec8\u4e8e\u5b9e\u73b0\u4e86\u767b\u5f55\u529f\u80fd\uff01<\/p>\n
\u5173\u4e8eAPI\u7684\u8c03\u7528\uff0c\u7a0d\u5fae\u8be6\u7ec6\u89e3\u91ca\u4e00\u4e0b\u3002<\/h3>\n
\u83b7\u53d6\u4ee4\u724c\u3002<\/h4>\n
\u83b7\u53d6\u4eceCognito\u83b7\u53d6\u8bbf\u95ee\u4ee4\u724c\u7684\u51fd\u6570\u3002
\n– URL\u5e94\u8bbe\u7f6e\u4e3a\u201chttps:\/\/\u8bbe\u7f6e\u7684\u57df\u540d.auth.\u533a\u57df.amazoncognito.com\/oauth2\/token\u201d\u3002
\n– client_id\u5e94\u8bbe\u7f6e\u4e3a\u5728\u7528\u6237\u6c60\u4e2d\u8bbe\u7f6e\u7684\u201c\u5e94\u7528\u7a0b\u5e8f\u5ba2\u6237\u7aefID\u201d\u3002
\n– redirect_uri\u5e94\u4e0e\u5e94\u7528\u7a0b\u5e8f\u5ba2\u6237\u7aef\u8bbe\u7f6e\u7684\u201c\u56de\u8c03URL\u201d\u5339\u914d\u3002
\n– code\u5e94\u8bbe\u7f6e\u4e3a\u8ba4\u8bc1\u9875\u9762\u91cd\u5b9a\u5411\u65f6\u63d0\u4f9b\u7684Get\u53c2\u6570code\u3002<\/p>\n
getTokens<\/span> :<\/span> _code<\/span> =><\/span> {<\/span>\r\n  return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n    url<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_tokenEndpoint<\/span>,<\/span>\r\n    method<\/span>:<\/span> \"<\/span>POST<\/span>\"<\/span>,<\/span>\r\n    contentType<\/span>:<\/span> \"<\/span>application\/x-www-form-urlencoded<\/span>\"<\/span>,<\/span>\r\n    data<\/span>:<\/span> {<\/span>\r\n      grant_type<\/span>:<\/span> \"<\/span>authorization_code<\/span>\"<\/span>,<\/span>\r\n      client_id<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_clientid<\/span>,<\/span>\r\n      redirect_uri<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_redirecturl<\/span>,<\/span>\r\n      code<\/span>:<\/span> _code<\/span>,<\/span>\r\n    },<\/span>\r\n  })<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n
\u83b7\u53d6\u7528\u6237\u4fe1\u606f<\/h4>\n
\u4f7f\u7528Cognito\u83b7\u53d6\u5f53\u524d\u767b\u5f55\u7528\u6237\u4fe1\u606f\u7684\u51fd\u6570\u3002
\n\u00b7\u5c06URL\u8bbe\u7f6e\u4e3a”https:\/\/\u8bbe\u7f6e\u7684\u57df\u540d.auth.\u5730\u533a.amazoncognito.com\/oauth2\/userInfo”\u3002
\n\u00b7\u5c06\u6388\u6743\u5934\u90e8\u8bbe\u7f6e\u4e3a”Bearer ” + jwt\u3002<\/p>\n
getUser<\/span> :<\/span> ()<\/span> =><\/span> {<\/span>\r\n  return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n    url<\/span>:<\/span> opt<\/span>.<\/span>aws_cognito_userEndpoint<\/span>,<\/span>\r\n    method<\/span>:<\/span> \"<\/span>GET<\/span>\"<\/span>,<\/span>\r\n    contentType<\/span>:<\/span> \"<\/span>application\/json<\/span>\"<\/span>,<\/span>\r\n    headers<\/span>:<\/span> {<\/span>\r\n      Authorization<\/span>:<\/span> \"<\/span>Bearer <\/span>\"<\/span>+<\/span>_cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>\r\n    },<\/span>\r\n  })<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n
\u8ba4\u77e5.api.graphql<\/h4>\n
\u8c03\u7528Appsync\u7684GraphQL API\u51fd\u6570
\n– \u5c06url\u8bbe\u7f6e\u4e3aAppsync\u201c\u8bbe\u7f6e\u201d\u4e2d\u7684API URL
\n– \u5728Authorization\u5934\u4e2d\u8bbe\u7f6ejwt\u4f5c\u4e3a\u6388\u6743<\/p>\n
graphql<\/span> :<\/span> (<\/span>_query<\/span>)<\/span> =><\/span> {<\/span>\r\n  return<\/span> $<\/span>.<\/span>ajax<\/span>({<\/span>\r\n    url<\/span>:<\/span> opt<\/span>.<\/span>aws_appsync_graphqlEndpoint<\/span>,<\/span>\r\n    method<\/span>:<\/span> \"<\/span>POST<\/span>\"<\/span>,<\/span>\r\n    contentType<\/span>:<\/span> \"<\/span>application\/json<\/span>\"<\/span>,<\/span>\r\n    headers<\/span>:<\/span> {<\/span>\r\n      Authorization<\/span>:<\/span> _cognito<\/span>.<\/span>storage<\/span>.<\/span>jwt<\/span>\r\n    },<\/span>\r\n    data<\/span>:<\/span> JSON<\/span>.<\/span>stringify<\/span>(<\/span>_query<\/span>),<\/span>\r\n  })<\/span>\r\n}<\/span>\r\n<\/code><\/pre>\n
\u901a\u8fc7\u7f51\u7ad9\u6d4b\u8bd5Appsync\u7684\u8ba2\u9605\u529f\u80fd\u3002<\/h2>\n
\u4ee5\u4e0b\u662f\u6309\u7167\u4ee5\u4e0b\u987a\u5e8f\u68c0\u67e5\u8ba2\u9605\u7684\u6b65\u9aa4\uff1a
\n1. \u6267\u884cGraphQL\u7684subscription\u3002
\n2. \u63a5\u6536\u8fd4\u56de\u503c\u4e2d\u7684MQTT\u8fde\u63a5\u4fe1\u606f\uff0c\u521b\u5efa\u5e76\u8fde\u63a5Paho.MQTT.Client\u3002
\n3. \u8fde\u63a5\u540e\uff0c\u8fdb\u884c\u8ba2\u9605\u5e76\u63a5\u6536\u6d88\u606f\u3002
\n4. \u6536\u5230\u6d88\u606f\u540e\uff0c\u5728\u63a7\u5236\u53f0\u4e0a\u8f93\u51fa\u65e5\u5fd7\u3002<\/p>\n
var<\/span> onConnect<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span> \/\/3.\u63a5\u7d9a\u5f8c\u3001subscribe\u3092\u3057\u3066\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u53d7\u3051\u4ed8\u3051\u308b\u95a2\u6570<\/span>\r\n  console<\/span>.<\/span>log<\/span>(<\/span>\"<\/span>onConnect!<\/span>\"<\/span>);<\/span>\r\n  console<\/span>.<\/span>log<\/span>(<\/span>x<\/span>);<\/span>\r\n  client<\/span>.<\/span>subscribe<\/span>(<\/span>sub<\/span>.<\/span>topics<\/span>);<\/span>\r\n};<\/span>\r\nvar<\/span> onMessageArrived<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span> \/\/4.\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u53d7\u3051\u53d6\u308b\u3068\u3001\u30b3\u30f3\u30bd\u30fc\u30eb\u306b\u30ed\u30b0\u3092\u51fa\u529b\u3059\u308b\u95a2\u6570<\/span>\r\n  console<\/span>.<\/span>log<\/span>(<\/span>\"<\/span>onMessageArrived!<\/span>\"<\/span>);<\/span>\r\n  console<\/span>.<\/span>log<\/span>(<\/span>x<\/span>.<\/span>payloadString<\/span>);<\/span>\r\n};<\/span>\r\nvar<\/span> onConnectionLost<\/span> =<\/span> function<\/span>(<\/span>x<\/span>){<\/span>\r\n  console<\/span>.<\/span>log<\/span>(<\/span>\"<\/span>onConnectionLost!<\/span>\"<\/span>);<\/span>\r\n  console<\/span>.<\/span>log<\/span>(<\/span>x<\/span>);<\/span>\r\n};<\/span>\r\n\/\/subscription\u958b\u59cb<\/span>\r\n_cognito<\/span>.<\/span>api<\/span>.<\/span>graphql<\/span>({<\/span> \/\/1.GraphQL\u306esubscription\u3092\u5b9f\u884c\u3059\u308b<\/span>\r\n  query<\/span>:<\/span> `\r\n    subscription NewPostSub {\r\n      onCreatePost {\r\n        id\r\n        postDate\r\n        message\r\n      }\r\n    }\r\n  `<\/span>\r\n})<\/span>\r\n.<\/span>then<\/span>(<\/span>x<\/span>=><\/span>{<\/span> \/\/2.\u623b\u308a\u5024\u3067MQTT\u63a5\u7d9a\u60c5\u5831\u304c\u8fd4\u3063\u3066\u6765\u308b\u305f\u3081\u3001Paho.MQTT.Client\u3092\u4f5c\u6210\u3057\u3001\u63a5\u7d9a\u3059\u308b<\/span>\r\n  sub<\/span> =<\/span> {<\/span>\r\n    wssUrl<\/span>:<\/span> x<\/span>.<\/span>extensions<\/span>.<\/span>subscription<\/span>.<\/span>mqttConnections<\/span>[<\/span>0<\/span>].<\/span>url<\/span>,<\/span>\r\n    client<\/span>:<\/span> x<\/span>.<\/span>extensions<\/span>.<\/span>subscription<\/span>.<\/span>mqttConnections<\/span>[<\/span>0<\/span>].<\/span>client<\/span>,<\/span>\r\n    topics<\/span>:<\/span> x<\/span>.<\/span>extensions<\/span>.<\/span>subscription<\/span>.<\/span>mqttConnections<\/span>[<\/span>0<\/span>].<\/span>topics<\/span>[<\/span>0<\/span>],<\/span>\r\n  }<\/span>\r\n  client<\/span> =<\/span> new<\/span> Paho<\/span>.<\/span>MQTT<\/span>.<\/span>Client<\/span>(<\/span>sub<\/span>.<\/span>wssUrl<\/span>,<\/span> sub<\/span>.<\/span>client<\/span>);<\/span>\r\n  var<\/span> connectOptions<\/span> =<\/span> {<\/span>\r\n      onSuccess<\/span>:<\/span> onConnect<\/span>,<\/span> \/\/3.\u63a5\u7d9a\u5f8c\u3001subscribe\u3092\u3057\u3066\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u53d7\u3051\u4ed8\u3051\u308b\u95a2\u6570\u306e\u767b\u9332<\/span>\r\n      useSSL<\/span>:<\/span> true<\/span>,<\/span>\r\n      timeout<\/span>:<\/span> 3<\/span>,<\/span>\r\n      mqttVersion<\/span>:<\/span> 4<\/span>,<\/span>\r\n      onFailure<\/span>:<\/span> function<\/span>(<\/span>x<\/span>)<\/span> {<\/span>\r\n          console<\/span>.<\/span>log<\/span>(<\/span>\"<\/span>connect failed!<\/span>\"<\/span>);<\/span>\r\n          console<\/span>.<\/span>log<\/span>(<\/span>x<\/span>);<\/span>\r\n      }<\/span>\r\n  };<\/span>\r\n  client<\/span>.<\/span>onMessageArrived<\/span> =<\/span> onMessageArrived<\/span>;<\/span> \/\/4.\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u53d7\u3051\u53d6\u308b\u3068\u3001\u30b3\u30f3\u30bd\u30fc\u30eb\u306b\u30ed\u30b0\u3092\u51fa\u529b\u3059\u308b\u95a2\u6570\u306e\u767b\u9332<\/span>\r\n  client<\/span>.<\/span>onConnectionLost<\/span> =<\/span> onConnectionLost<\/span>;<\/span>\r\n  client<\/span>.<\/span>connect<\/span>(<\/span>connectOptions<\/span>);<\/span>\r\n})<\/span>\r\n.<\/span>fail<\/span>(<\/span>x<\/span>=><\/span>console<\/span>.<\/span>log<\/span>(<\/span>x<\/span>));<\/span>\r\n\r\n<\/code><\/pre>\n
\"image.png\"<\/div>\n
\u7d50\u675f<\/h1>\n
\u611f\u8c22\u60a8\u7684\u89c2\u770b\u3002
\n\u5c3d\u7ba1\u65e5\u8bed\u4fe1\u606f\u76f8\u5f53\u6709\u9650\u4e14\u56f0\u96be\uff0c\u4f46\u6211\u5df2\u7ecf\u6210\u529f\u4f7f\u7528\u7b80\u5355\u7684JavaScript\u5b9e\u73b0\u4e86\u5bf9Cognito\u7684\u767b\u5f55\uff0c\u5e76\u4f7f\u7528Appsync\u6267\u884c\u4e86GraphQL\u67e5\u8be2\/\u53d8\u5f02\/\u8ba2\u9605\u3002
\n\u63a5\u4e0b\u6765\uff0c\u6211\u60f3\u786e\u8ba4\u5982\u4f55\u521b\u5efa\u623f\u95f4\u5e76\u4f7f\u7279\u5b9a\u7528\u6237\u4ec5\u80fd\u8fdb\u884c\u8ba2\u9605\uff0c\u4ee5\u53ca\u5728\u79bb\u7ebf\u72b6\u6001\u4e0b\u7684\u64cd\u4f5c\u7b49\u5185\u5bb9\u3002<\/p>\n
\u5982\u679c\u6709\u4e0d\u8db3\u4e4b\u5904\uff0c\u8bf7\u60a8\u7559\u4e0b\u8bc4\u8bba\uff0c\u6211\u5c06\u4e0d\u80dc\u611f\u6fc0\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u9996\u5148 \u4f60\u597d\uff0c\u4eca\u5929\u662f2018\u5e74Serverless Advent Calendar\u7684\u7b2c\u5341\u4e5d\u5929\u3002 \u8fc7\u53bb\u6211\u53ea\u662f\u89c2\u770b\u8fc7 […]<\/p>\n","protected":false},"author":11,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-48348","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"\n\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u8bd5\u7528\u7b80\u6613\u7684-javascript-\u7248-aws-appsync\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync\" \/>\n<meta property=\"og:description\" content=\"\u9996\u5148 \u4f60\u597d\uff0c\u4eca\u5929\u662f2018\u5e74Serverless Advent Calendar\u7684\u7b2c\u5341\u4e5d\u5929\u3002 \u8fc7\u53bb\u6211\u53ea\u662f\u89c2\u770b\u8fc7 […]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u8bd5\u7528\u7b80\u6613\u7684-javascript-\u7248-aws-appsync\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-11-25T16:06:11+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-04-28T15:22:01+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d844f913a08637a6b5dfd\/11-0.png\" \/>\n<meta name=\"author\" content=\"\u65b0, \u97f5\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u65b0, \u97f5\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"6 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/\",\"name\":\"\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-11-25T16:06:11+00:00\",\"dateModified\":\"2024-04-28T15:22:01+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/4ba4019495123db3038fd0809e6959c9\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/4ba4019495123db3038fd0809e6959c9\",\"name\":\"\u65b0, \u97f5\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/d484b6c6e4ae82e8a9efea989e1d2af46d9b6ef128101e63b18f559fca0ae627?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/d484b6c6e4ae82e8a9efea989e1d2af46d9b6ef128101e63b18f559fca0ae627?s=96&d=mm&r=g\",\"caption\":\"\u65b0, \u97f5\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunxin\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u8bd5\u7528\u7b80\u6613\u7684-javascript-\u7248-aws-appsync\/","og_locale":"zh_CN","og_type":"article","og_title":"\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync","og_description":"\u9996\u5148 \u4f60\u597d\uff0c\u4eca\u5929\u662f2018\u5e74Serverless Advent Calendar\u7684\u7b2c\u5341\u4e5d\u5929\u3002 \u8fc7\u53bb\u6211\u53ea\u662f\u89c2\u770b\u8fc7 […]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u8bd5\u7528\u7b80\u6613\u7684-javascript-\u7248-aws-appsync\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-11-25T16:06:11+00:00","article_modified_time":"2024-04-28T15:22:01+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d844f913a08637a6b5dfd\/11-0.png"}],"author":"\u65b0, \u97f5","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u65b0, \u97f5","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"6 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/","name":"\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-11-25T16:06:11+00:00","dateModified":"2024-04-28T15:22:01+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/4ba4019495123db3038fd0809e6959c9"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u8bd5\u7528\u7b80\u6613\u7684 JavaScript \u7248 AWS AppSync"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/4ba4019495123db3038fd0809e6959c9","name":"\u65b0, \u97f5","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/d484b6c6e4ae82e8a9efea989e1d2af46d9b6ef128101e63b18f559fca0ae627?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/d484b6c6e4ae82e8a9efea989e1d2af46d9b6ef128101e63b18f559fca0ae627?s=96&d=mm&r=g","caption":"\u65b0, \u97f5"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/yunxin\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e8%af%95%e7%94%a8%e7%ae%80%e6%98%93%e7%9a%84-javascript-%e7%89%88-aws-appsync\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/48348","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/11"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=48348"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/48348\/revisions"}],"predecessor-version":[{"id":64673,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/48348\/revisions\/64673"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=48348"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=48348"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=48348"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}