{"id":2012,"date":"2023-06-21T06:33:11","date_gmt":"2023-06-20T22:33:11","guid":{"rendered":"http:\/\/viplao.com\/?p=2012"},"modified":"2023-06-21T06:33:13","modified_gmt":"2023-06-20T22:33:13","slug":"flinksql%e5%ae%9e%e8%b7%b5-%e5%a6%82%e4%bd%95%e5%ae%9e%e6%97%b6%e7%bb%9f%e8%ae%a1%e6%9c%80%e8%bf%91-15-%e7%a7%92%e7%9a%84%e5%95%86%e5%93%81%e9%94%80%e5%94%ae%e9%a2%9d","status":"publish","type":"post","link":"http:\/\/viplao.com\/index.php\/2023\/06\/21\/flinksql%e5%ae%9e%e8%b7%b5-%e5%a6%82%e4%bd%95%e5%ae%9e%e6%97%b6%e7%bb%9f%e8%ae%a1%e6%9c%80%e8%bf%91-15-%e7%a7%92%e7%9a%84%e5%95%86%e5%93%81%e9%94%80%e5%94%ae%e9%a2%9d\/","title":{"rendered":"flinkSQL\u5b9e\u8df5 &#8211; \u5982\u4f55\u5b9e\u65f6\u7edf\u8ba1\u6700\u8fd1 15 \u79d2\u7684\u5546\u54c1\u9500\u552e\u989d"},"content":{"rendered":"\n<p>\u60f3\u8981\u4e86\u89e3\u5982\u4f55\u4f7f\u7528 Flink \u5b9e\u65f6\u7edf\u8ba1\u6700\u8fd1 15 \u79d2\u7684\u5546\u54c1\u9500\u552e\u989d\u5417\uff1f\u672c\u5b9e\u9a8c\u5c06\u4ee5\u963f\u91cc\u4e91\u5b9e\u65f6\u8ba1\u7b97 Flink \u7248\u4e3a\u57fa\u7840\uff0c\u4f7f\u7528 Flink \u81ea\u5e26\u7684 MySQL Connector \u8fde\u63a5 RDS \u4e91\u6570\u636e\u5e93\u5b9e\u4f8b\uff0c\u5e76\u4ee5\u5b9e\u65f6\u5546\u54c1\u9500\u552e\u6570\u636e\u7edf\u8ba1\u7684\u4f8b\u5b50\uff0c\u5f15\u5bfc\u5f00\u53d1\u8005\u4e0a\u624b Connector \u7684\u6570\u636e\u6355\u83b7\u3001\u6570\u636e\u5199\u5165\u7b49\u529f\u80fd\u3002<\/p>\n\n\n\n<p>\u5b8c\u6210\u672c\u6b21\u5b9e\u9a8c\u540e\uff0c\u60a8\u5c06\u638c\u63e1\u7684\u77e5\u8bc6\u6709\uff1a<\/p>\n\n\n\n<ul>\n<li>\u4f7f\u7528 Flink \u5b9e\u65f6\u8ba1\u7b97\u5e73\u53f0\u521b\u5efa\u5e76\u63d0\u4ea4\u4f5c\u4e1a\u7684\u65b9\u6cd5\uff1b<\/li>\n\n\n\n<li>\u7f16\u5199\u57fa\u4e8e Flink Table API SQL \u8bed\u53e5\u7684\u80fd\u529b\uff1b<\/li>\n\n\n\n<li>\u4f7f\u7528 MySQL Connector \u5bf9\u6570\u636e\u5e93\u8fdb\u884c\u8bfb\u5199\u7684\u65b9\u6cd5\u3002<\/li>\n<\/ul>\n\n\n\n<div id=\"ez-toc-container\" class=\"ez-toc-v2_0_71 counter-hierarchy ez-toc-counter ez-toc-grey ez-toc-container-direction\">\n<div class=\"ez-toc-title-container\">\n<p class=\"ez-toc-title\" style=\"cursor:inherit\">\u6587\u7ae0\u76ee\u5f55<\/p>\n<span class=\"ez-toc-title-toggle\"><a href=\"#\" class=\"ez-toc-pull-right ez-toc-btn ez-toc-btn-xs ez-toc-btn-default ez-toc-toggle\" aria-label=\"Toggle Table of Content\"><span class=\"ez-toc-js-icon-con\"><span class=\"\"><span class=\"eztoc-hide\" style=\"display:none;\">Toggle<\/span><span class=\"ez-toc-icon-toggle-span\"><svg style=\"fill: #999;color:#999\" xmlns=\"http:\/\/www.w3.org\/2000\/svg\" class=\"list-377408\" width=\"20px\" height=\"20px\" viewBox=\"0 0 24 24\" fill=\"none\"><path d=\"M6 6H4v2h2V6zm14 0H8v2h12V6zM4 11h2v2H4v-2zm16 0H8v2h12v-2zM4 16h2v2H4v-2zm16 0H8v2h12v-2z\" fill=\"currentColor\"><\/path><\/svg><svg style=\"fill: #999;color:#999\" class=\"arrow-unsorted-368013\" xmlns=\"http:\/\/www.w3.org\/2000\/svg\" width=\"10px\" height=\"10px\" viewBox=\"0 0 24 24\" version=\"1.2\" baseProfile=\"tiny\"><path d=\"M18.2 9.3l-6.2-6.3-6.2 6.3c-.2.2-.3.4-.3.7s.1.5.3.7c.2.2.4.3.7.3h11c.3 0 .5-.1.7-.3.2-.2.3-.5.3-.7s-.1-.5-.3-.7zM5.8 14.7l6.2 6.3 6.2-6.3c.2-.2.3-.5.3-.7s-.1-.5-.3-.7c-.2-.2-.4-.3-.7-.3h-11c-.3 0-.5.1-.7.3-.2.2-.3.5-.3.7s.1.5.3.7z\"\/><\/svg><\/span><\/span><\/span><\/a><\/span><\/div>\n<nav><ul class='ez-toc-list ez-toc-list-level-1 eztoc-toggle-hide-by-default' ><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-1\" href=\"http:\/\/viplao.com\/index.php\/2023\/06\/21\/flinksql%e5%ae%9e%e8%b7%b5-%e5%a6%82%e4%bd%95%e5%ae%9e%e6%97%b6%e7%bb%9f%e8%ae%a1%e6%9c%80%e8%bf%91-15-%e7%a7%92%e7%9a%84%e5%95%86%e5%93%81%e9%94%80%e5%94%ae%e9%a2%9d\/#Flink_MySQL_Connector_%E7%AE%80%E4%BB%8B\" title=\"Flink MySQL Connector \u7b80\u4ecb\">Flink MySQL Connector \u7b80\u4ecb<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-2\" href=\"http:\/\/viplao.com\/index.php\/2023\/06\/21\/flinksql%e5%ae%9e%e8%b7%b5-%e5%a6%82%e4%bd%95%e5%ae%9e%e6%97%b6%e7%bb%9f%e8%ae%a1%e6%9c%80%e8%bf%91-15-%e7%a7%92%e7%9a%84%e5%95%86%e5%93%81%e9%94%80%e5%94%ae%e9%a2%9d\/#%E6%AD%A5%E9%AA%A4%E4%B8%80%EF%BC%9A%E5%88%9B%E5%BB%BA%E8%B5%84%E6%BA%90\" title=\"\u6b65\u9aa4\u4e00\uff1a\u521b\u5efa\u8d44\u6e90\">\u6b65\u9aa4\u4e00\uff1a\u521b\u5efa\u8d44\u6e90<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-3\" href=\"http:\/\/viplao.com\/index.php\/2023\/06\/21\/flinksql%e5%ae%9e%e8%b7%b5-%e5%a6%82%e4%bd%95%e5%ae%9e%e6%97%b6%e7%bb%9f%e8%ae%a1%e6%9c%80%e8%bf%91-15-%e7%a7%92%e7%9a%84%e5%95%86%e5%93%81%e9%94%80%e5%94%ae%e9%a2%9d\/#%E6%AD%A5%E9%AA%A4%E4%BA%8C%EF%BC%9A%E5%88%9B%E5%BB%BA%E6%95%B0%E6%8D%AE%E5%BA%93%E8%A1%A8\" title=\"\u6b65\u9aa4\u4e8c\uff1a\u521b\u5efa\u6570\u636e\u5e93\u8868\">\u6b65\u9aa4\u4e8c\uff1a\u521b\u5efa\u6570\u636e\u5e93\u8868<\/a><\/li><li class='ez-toc-page-1 ez-toc-heading-level-2'><a class=\"ez-toc-link ez-toc-heading-4\" href=\"http:\/\/viplao.com\/index.php\/2023\/06\/21\/flinksql%e5%ae%9e%e8%b7%b5-%e5%a6%82%e4%bd%95%e5%ae%9e%e6%97%b6%e7%bb%9f%e8%ae%a1%e6%9c%80%e8%bf%91-15-%e7%a7%92%e7%9a%84%e5%95%86%e5%93%81%e9%94%80%e5%94%ae%e9%a2%9d\/#%E6%AD%A5%E9%AA%A4%E4%B8%89%EF%BC%9A%E5%88%9B%E5%BB%BA_Flink_%E4%BD%9C%E4%B8%9A\" title=\"\u6b65\u9aa4\u4e09\uff1a\u521b\u5efa Flink \u4f5c\u4e1a\">\u6b65\u9aa4\u4e09\uff1a\u521b\u5efa Flink \u4f5c\u4e1a<\/a><\/li><\/ul><\/nav><\/div>\n<h2 class=\"wp-block-heading\" id=\"slide-0\"><span class=\"ez-toc-section\" id=\"Flink_MySQL_Connector_%E7%AE%80%E4%BB%8B\"><\/span>Flink MySQL Connector \u7b80\u4ecb<span class=\"ez-toc-section-end\"><\/span><\/h2>\n\n\n\n<p>MySQL Connector \u53ef\u4ee5\u5c06\u672c\u5730\u6216\u8fdc\u7a0b\u7684 MySQL \u6570\u636e\u5e93\u8fde\u63a5\u5230 Flink \u4e2d\uff0c\u5e76\u65b9\u4fbf\u5730\u4f7f\u7528 Flink Table API \u4e0e\u4e4b\u4ea4\u4e92\u3001\u6355\u83b7\u6570\u636e\u53d8\u66f4\u3001\u5e76\u5c06\u5904\u7406\u7ed3\u679c\u5199\u56de\u6570\u636e\u5e93\u3002\u672c\u5b9e\u9a8c\u4e3b\u8981\u4ecb\u7ecd\u5982\u4f55\u5728\u963f\u91cc\u4e91\u5b9e\u65f6\u8ba1\u7b97\u5e73\u53f0\u4e0a\u4f7f\u7528 Flink MySQL \u8fde\u63a5\u5668\u7684\u76f8\u5173\u529f\u80fd\uff0c\u5e76\u4f7f\u7528 Table API \u7f16\u5199\u4e00\u4e2a\u7b80\u5355\u7684\u4f8b\u5b50\uff0c\u5c1d\u8bd5 MySQL \u4f5c\u4e3a\u6e90\u8868\u3001\u7ef4\u8868\u3001\u6c47\u8868\u7684\u4e0d\u540c\u529f\u80fd\u3002<\/p>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"slide-1\"><span class=\"ez-toc-section\" id=\"%E6%AD%A5%E9%AA%A4%E4%B8%80%EF%BC%9A%E5%88%9B%E5%BB%BA%E8%B5%84%E6%BA%90\"><\/span>\u6b65\u9aa4\u4e00\uff1a\u521b\u5efa\u8d44\u6e90<span class=\"ez-toc-section-end\"><\/span><\/h2>\n\n\n\n<p>\u5f00\u59cb\u5b9e\u9a8c\u4e4b\u524d\uff0c\u60a8\u9700\u8981\u5f00\u901a\u963f\u91cc\u4e91\u5b9e\u65f6\u8ba1\u7b97 Flink \u7248\uff0c\u521b\u5efa\u5b9e\u9a8c\u8d44\u6e90\u3002<\/p>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"slide-2\"><span class=\"ez-toc-section\" id=\"%E6%AD%A5%E9%AA%A4%E4%BA%8C%EF%BC%9A%E5%88%9B%E5%BB%BA%E6%95%B0%E6%8D%AE%E5%BA%93%E8%A1%A8\"><\/span>\u6b65\u9aa4\u4e8c\uff1a\u521b\u5efa\u6570\u636e\u5e93\u8868<span class=\"ez-toc-section-end\"><\/span><\/h2>\n\n\n\n<p>\u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u5c06\u521b\u5efa\u4e09\u5f20\u6570\u636e\u8868\uff0c\u5206\u522b\u4f5c\u4e3a\u6e90\u8868\u3001\u7ef4\u8868\u3001\u6c47\u8868\uff0c\u6f14\u793a MySQL Connector \u7684\u4e0d\u540c\u529f\u80fd\u3002<\/p>\n\n\n\n<ol>\n<li>\u8fdb\u5165\u4e91\u6570\u636e\u5e93 RDS \u540e\u53f0\uff0c\u5e76\u767b\u5f55\u521a\u521a\u521b\u5efa\u8d44\u6e90\u7684\u540e\u53f0\u9875\u9762\u3002<\/li>\n\n\n\n<li>\u70b9\u51fb\u5de6\u4fa7\u8fb9\u680f\u7684 + \u52a0\u53f7\u6309\u94ae\uff0c\u521b\u5efa\u4e00\u4e2a\u6d4b\u8bd5\u7528\u6570\u636e\u5e93\uff0c\u7136\u540e\u5728\u53f3\u4fa7\u547d\u4ee4\u533a\u8f93\u5165\u4ee5\u4e0b\u5efa\u8868\u6307\u4ee4\u5e76\u6267\u884c\uff1a<\/li>\n<\/ol>\n\n\n\n<pre class=\"wp-block-code\"><code><em>-- Source Table;<\/em>\nCREATE TABLE `source_table` (\n  `id` int unsigned NOT NULL AUTO_INCREMENT,\n  `good_id` int DEFAULT NULL,\n  `amount` int DEFAULT NULL,\n  `record_time` timestamp NULL DEFAULT NULL,\n  PRIMARY KEY (`id`)\n);\n\n<em>-- Dimension Table;<\/em>\nCREATE TABLE `dimension_table` (\n  `good_id` int unsigned NOT NULL,\n  `good_name` varchar(256) DEFAULT NULL,\n  `good_price` int DEFAULT NULL,\n  PRIMARY KEY (`good_id`)\n);\n\n<em>-- Sink Table;<\/em>\nCREATE TABLE `sink_table` (\n  `record_timestamp` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,\n  `good_name` varchar(128) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT NULL,\n  `sell_amount` int DEFAULT NULL,\n  PRIMARY KEY (`record_timestamp`)\n);\n<\/code><\/pre>\n\n\n\n<h2 class=\"wp-block-heading\" id=\"slide-3\"><span class=\"ez-toc-section\" id=\"%E6%AD%A5%E9%AA%A4%E4%B8%89%EF%BC%9A%E5%88%9B%E5%BB%BA_Flink_%E4%BD%9C%E4%B8%9A\"><\/span>\u6b65\u9aa4\u4e09\uff1a\u521b\u5efa Flink \u4f5c\u4e1a<span class=\"ez-toc-section-end\"><\/span><\/h2>\n\n\n\n<ol>\n<li>\u8fdb\u5165\u5b9e\u65f6\u8ba1\u7b97 Flink \u5e73\u53f0\uff0c\u70b9\u51fb\u5de6\u4fa7\u8fb9\u680f\u4e2d\u7684\u300c\u5e94\u7528\u300d\u2014\u300c\u4f5c\u4e1a\u5f00\u53d1\u300d\u83dc\u5355\uff0c\u5e76\u70b9\u51fb\u9876\u90e8\u5de5\u5177\u680f\u7684\u300c\u65b0\u5efa\u300d\u6309\u94ae\u65b0\u5efa\u4e00\u4e2a\u4f5c\u4e1a\u3002\u4f5c\u4e1a\u540d\u5b57\u4efb\u610f\uff0c\u7c7b\u578b\u9009\u62e9\u300c\u6d41\u4f5c\u4e1a \/ SQL\u300d\uff0c\u5176\u4f59\u8bbe\u7f6e\u4fdd\u6301\u9ed8\u8ba4\u3002\u5982\u4e0b\u6240\u793a\uff1a<\/li>\n<\/ol>\n\n\n\n<ol>\n<li>\u6210\u529f\u521b\u5efa\u4f5c\u4e1a\u540e\uff0c\u53f3\u4fa7\u7f16\u8f91\u7a97\u683c\u5e94\u8be5\u663e\u793a\u65b0\u4f5c\u4e1a\u7684\u5185\u5bb9\uff1a<\/li>\n<\/ol>\n\n\n\n<figure class=\"wp-block-image size-full\"><img decoding=\"async\" loading=\"lazy\" width=\"646\" height=\"430\" src=\"http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_33b2361b7bf04cedb16626755339e1f7.png\" alt=\"\" class=\"wp-image-2022\" srcset=\"http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_33b2361b7bf04cedb16626755339e1f7.png 646w, http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_33b2361b7bf04cedb16626755339e1f7-300x200.png 300w, http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_33b2361b7bf04cedb16626755339e1f7-451x300.png 451w\" sizes=\"(max-width: 646px) 100vw, 646px\" \/><\/figure>\n\n\n\n<ol>\n<li>\u63a5\u4e0b\u6765\uff0c\u6211\u4eec\u5728\u53f3\u4fa7\u7f16\u8f91\u7a97\u683c\u4e2d\u8f93\u5165\u4ee5\u4e0b\u8bed\u53e5\u6765\u521b\u5efa\u4e00\u5f20\u4e34\u65f6\u8868\uff0c\u5e76\u4f7f\u7528 MySQL CDC \u8fde\u63a5\u5668\u5b9e\u65f6\u6355\u83b7&nbsp;<code>source_table<\/code>\u7684\u53d8\u5316\uff1a<\/li>\n<\/ol>\n\n\n\n<pre class=\"wp-block-code\"><code>CREATE TEMPORARY TABLE source_table (\n    id INT NOT NULL PRIMARY KEY NOT ENFORCED,\n    record_time TIMESTAMP_LTZ(3),\n    good_id INT,\n    amount INT,\n    WATERMARK FOR record_time AS record_time - INTERVAL '5' SECOND\n) WITH (\n    'connector' = 'mysql-cdc',\n    'hostname' = '******************.mysql.rds.aliyuncs.com',\n    'port' = '3306',\n    'username' = '***********',\n    'password' = '***********',\n    'database-name' = '***********',\n    'table-name' = 'source_table'\n);\n<\/code><\/pre>\n\n\n\n<p>\u9700\u8981\u5c06&nbsp;<code>hostname<\/code>\u53c2\u6570\u66ff\u6362\u4e3a\u65e9\u4e9b\u65f6\u5019\u521b\u5efa\u8d44\u6e90\u7684\u57df\u540d\u3001\u5c06&nbsp;<code>username<\/code>\u548c&nbsp;<code>password<\/code>\u53c2\u6570\u66ff\u6362\u4e3a\u6570\u636e\u5e93\u767b\u5f55\u7528\u6237\u540d\u53ca\u5bc6\u7801\u3001\u5c06&nbsp;<code>database-name<\/code>\u53c2\u6570\u66ff\u6362\u4e3a\u4e4b\u524d\u5728 RDS \u540e\u53f0\u4e2d\u521b\u5efa\u7684\u6570\u636e\u5e93\u540d\u79f0\u3002<\/p>\n\n\n\n<p>\u5176\u4e2d\uff0c<code>'connector' = 'mysql-cdc'<\/code>\u6307\u5b9a\u4e86\u4f7f\u7528 MySQL CDC \u8fde\u63a5\u5668\u6765\u6355\u83b7\u53d8\u5316\u6570\u636e\u3002\u60a8\u9700\u8981\u4f7f\u7528\u51c6\u5907\u6b65\u9aa4\u4e2d\u7533\u8bf7\u7684 RDS MySQL URL\u3001\u7528\u6237\u540d\u3001\u5bc6\u7801\uff0c\u4ee5\u53ca\u4e4b\u524d\u521b\u5efa\u7684\u6570\u636e\u5e93\u540d\u66ff\u6362\u5bf9\u5e94\u90e8\u5206\u3002<\/p>\n\n\n\n<p>\u4efb\u4f55\u65f6\u5019\u60a8\u90fd\u53ef\u4ee5\u70b9\u51fb\u9876\u90e8\u5de5\u5177\u680f\u4e2d\u7684\u300c\u9a8c\u8bc1\u300d\u6309\u94ae\uff0c\u6765\u786e\u8ba4\u4f5c\u4e1a Flink SQL \u8bed\u53e5\u4e2d\u662f\u5426\u5b58\u5728\u8bed\u6cd5\u9519\u8bef\u3002<\/p>\n\n\n\n<ol>\n<li>\u4e3a\u4e86\u6d4b\u8bd5\u662f\u5426\u6210\u529f\u5730\u6355\u83b7\u4e86\u6e90\u8868\u6570\u636e\uff0c\u7d27\u63a5\u7740\u5728\u4e0b\u9762\u5199\u4e00\u884c\u00a0<code>SELECT * FROM source_table;<\/code>\u8bed\u53e5\uff0c\u5e76\u70b9\u51fb\u5de5\u5177\u680f\u4e2d\u7684\u300c\u6267\u884c\u300d\u6309\u94ae\u3002\u63a5\u7740\uff0c\u5411\u00a0<code>source_table<\/code>\u8868\u4e2d\u63d2\u5165\u4e00\u4e9b\u6570\u636e\u3002\u5982\u679c\u63a7\u5236\u53f0\u4e2d\u6253\u5370\u4e86\u76f8\u5e94\u7684\u6570\u636e\u884c\uff0c\u5219\u8bf4\u660e\u6355\u83b7\u6210\u529f\uff0c\u5982\u4e0b\u56fe\u6240\u793a\uff1a<br><\/li>\n<\/ol>\n\n\n\n<figure class=\"wp-block-image size-full\"><img decoding=\"async\" loading=\"lazy\" width=\"626\" height=\"498\" src=\"http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_160ceb5b67e24fc59ecb2ed21b4bedb6.png\" alt=\"\" class=\"wp-image-2024\" srcset=\"http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_160ceb5b67e24fc59ecb2ed21b4bedb6.png 626w, http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_160ceb5b67e24fc59ecb2ed21b4bedb6-300x239.png 300w, http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_160ceb5b67e24fc59ecb2ed21b4bedb6-377x300.png 377w\" sizes=\"(max-width: 626px) 100vw, 626px\" \/><\/figure>\n\n\n\n<ol>\n<li>\u63a5\u4e0b\u6765\uff0c\u6211\u4eec\u5e0c\u671b\u5bf9\u539f\u59cb\u6570\u636e\u6309\u7167\u65f6\u95f4\u7a97\u53e3\u8fdb\u884c\u5206\u7ec4\u8ba1\u7b97\u3002\u6211\u4eec\u4f7f\u7528&nbsp;<code>TUMBLE<\/code>\u76f8\u5173\u7a97\u53e3\u51fd\u6570\u7ed3\u5408&nbsp;<code>GROUP BY<\/code>\uff0c\u5c06\u957f\u5ea6 15 \u79d2\u5185\u7684\u8ba2\u5355\u6570\u636e\u6309\u7167\u5546\u54c1 ID \u8fdb\u884c\u5f52\u7c7b\uff0c\u5e76\u4f7f\u7528&nbsp;<code>SUM<\/code>\u8ba1\u7b97\u5176\u9500\u552e\u603b\u989d\u3002\u6211\u4eec\u5728 Flink \u4f5c\u4e1a\u7f16\u8f91\u7a97\u683c\u4e2d\u8f93\u5165\u5982\u4e0b\u4ee3\u7801\uff1a<\/li>\n<\/ol>\n\n\n\n<pre class=\"wp-block-code\"><code>SELECT \n  good_id, \n  tumble_start(\n    record_time, interval '15' seconds\n  ) AS record_timestamp, \n  sum(amount) AS total_amount \nFROM \n  source_table \nGROUP BY \n  tumble (\n    record_time, interval '15' seconds\n  ), \n  good_id;\n<\/code><\/pre>\n\n\n\n<p>\u4e3a\u4e86\u6d4b\u8bd5\u8fd9\u4e00\u6548\u679c\uff0c\u9700\u8981\u5411\u6570\u636e\u5e93\u4e2d\u63d2\u5165\u591a\u6761\u6570\u636e\u3002\u4f60\u53ef\u4ee5\u5728 RDS \u4e2d\u6267\u884c\u9644\u4ef6\u4e2d\u7684\u300c<code>\u793a\u4f8b\u6570\u636e.sql<\/code>\u300d\u6765\u63d2\u5165\u6570\u636e\uff0c\u6216\u8005\u4f7f\u7528\u300c<code>\u793a\u4f8b\u6570\u636e\u751f\u6210.py<\/code>\u300d\u811a\u672c\u5b9e\u65f6\u5730\u63d2\u5165\u6570\u636e\u3002<\/p>\n\n\n\n<p>\u5728\u4fdd\u8bc1\u6e90\u8868\u4e2d\u6709\u6570\u636e\u7684\u60c5\u51b5\u4e0b\uff0c\u518d\u6b21\u6267\u884c Flink \u4f5c\u4e1a\uff0c\u89c2\u5bdf\u63a7\u5236\u53f0\u7684\u8f93\u51fa\u7ed3\u679c\uff1a<\/p>\n\n\n\n<ol>\n<li>\u5728\u8fd9\u4e2a\u4e1a\u52a1\u573a\u666f\u4e2d\uff0c\u8d2d\u4e70\u5546\u54c1\u4fe1\u606f\u4f7f\u7528&nbsp;<code>good_id<\/code>\u8bb0\u5f55\uff0c\u800c\u5546\u54c1 ID \u5230\u53ef\u8bfb\u5546\u54c1\u540d\u5b57\u7684\u6620\u5c04\u8868\u3001\u6bcf\u4ef6\u5546\u54c1\u7684\u4ef7\u683c\u7b49\u4fe1\u606f\u5219\u5b58\u50a8\u5728\u53e6\u4e00\u5f20\u7ef4\u5ea6\u8868\uff08Dimension Table\uff09\u4e2d\u3002\u6211\u4eec\u540c\u6837\u53ef\u4ee5\u4f7f\u7528 Flink SQL \u8fde\u63a5\u7ef4\u5ea6\u8868\uff0c\u53ea\u9700\u5728 Flink \u4f5c\u4e1a\u4e2d\u7f16\u5199\u4e0b\u9762\u7684\u8bed\u53e5\uff1a<\/li>\n<\/ol>\n\n\n\n<pre class=\"wp-block-code\"><code>CREATE TEMPORARY TABLE dimension_table (\n    good_id INT NOT NULL PRIMARY KEY NOT ENFORCED,\n    good_name VARCHAR(256),\n    good_price INT\n) WITH (\n    'connector' = 'mysql',\n    'hostname' = '******************.mysql.rds.aliyuncs.com',\n    'port' = '3306',\n    'username' = '***********',\n    'password' = '***********',\n    'database-name' = '***********',\n    'table-name' = 'dimension_table'\n);\n<\/code><\/pre>\n\n\n\n<p>\u8fd9\u91cc\uff0c\u6211\u4eec\u5e0c\u671b\u6839\u636e\u4e0a\u4e00\u6b65\u4e2d\u7edf\u8ba1\u51fa\u7684\u300c\u6bcf 15 \u79d2\u5546\u54c1\u9500\u552e\u91cf\u300d\u4fe1\u606f\uff0c\u8ba1\u7b97\u51fa\u6bcf\u4ef6\u5546\u54c1\u7684\u9500\u552e\u989d\u3002\u7531\u4e8e\u5546\u54c1\u540d\u79f0\u53ca\u5546\u54c1\u4ef7\u683c\u6570\u636e\u5b58\u50a8\u5728\u53e6\u4e00\u5f20\u7ef4\u5ea6\u8868&nbsp;<code>dimension_table<\/code>\u4e2d\uff0c\u6211\u4eec\u9700\u8981\u5c06\u7ed3\u679c\u89c6\u56fe\u548c&nbsp;<code>dimension_table<\/code>\u8fdb\u884c JOIN \u64cd\u4f5c\uff0c\u5e76\u5c06\u300c\u5546\u54c1\u9500\u552e\u91cf\u300d\u3001\u300c\u5546\u54c1\u4ef7\u683c\u300d\u76f8\u4e58\u8ba1\u7b97\u51fa\u300c\u5546\u54c1\u9500\u552e\u989d\u300d\uff0c\u5e76\u63d0\u53d6\u7ed3\u679c\u4e2d\u7684\u5546\u54c1\u53ef\u8bfb\u540d\u79f0\u4fe1\u606f\u4f5c\u4e3a\u7ed3\u679c\u8868\u3002<\/p>\n\n\n\n<blockquote class=\"wp-block-quote\">\n<p>\u9700\u8981\u786e\u4fdd&nbsp;<code>dimension_table<\/code>\u4e2d\u5b58\u5728\u5bf9\u5e94\u5546\u54c1 ID \u7684\u6761\u76ee\u3002\u4f60\u53ef\u4ee5\u5728 RDS \u4e2d\u6267\u884c\u9644\u4ef6\u4e2d\u7684\u300c<code>\u793a\u4f8b\u6570\u636e.sql<\/code>\u300d\u6765\u63d2\u5165\u6570\u636e\u3002<\/p>\n<\/blockquote>\n\n\n\n<p>\u4f5c\u4e1a\u4ee3\u7801\u5982\u4e0b\uff1a<\/p>\n\n\n\n<pre class=\"wp-block-code\"><code>SELECT \n  record_timestamp, \n  good_name, \n  total_amount * good_price AS revenue \nFROM \n  (\n    SELECT \n      good_id, \n      tumble_start(\n        record_time, interval '15' seconds\n      ) AS record_timestamp, \n      sum(amount) AS total_amount \n    FROM \n      source_table \n    GROUP BY \n      tumble (\n        record_time, interval '15' seconds\n      ), \n      good_id\n  ) AS tumbled_table \n  LEFT JOIN dimension_table ON tumbled_table.good_id = dimension_table.good_id;\n<\/code><\/pre>\n\n\n\n<blockquote class=\"wp-block-quote\">\n<p>\u5176\u4e2d\u7b2c 7 \u5230 20 \u884c\u548c\u4e0a\u4e00\u6b65\u9aa4\u7684 SQL \u8bed\u53e5\u4e00\u81f4\u3002<\/p>\n<\/blockquote>\n\n\n\n<p>\u6267\u884c\u4e0a\u9762\u7684\u8bed\u53e5\uff0c\u5e76\u89c2\u5bdf\u63a7\u5236\u53f0\u4e2d\u7684\u7edf\u8ba1\u6570\u636e\uff1a<\/p>\n\n\n\n<figure class=\"wp-block-image size-large\"><img decoding=\"async\" loading=\"lazy\" width=\"1024\" height=\"305\" src=\"http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_020519befed9464785ff686dfd9be1d1-1024x305.png\" alt=\"\" class=\"wp-image-2025\" srcset=\"http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_020519befed9464785ff686dfd9be1d1-1024x305.png 1024w, http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_020519befed9464785ff686dfd9be1d1-300x89.png 300w, http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_020519befed9464785ff686dfd9be1d1-768x229.png 768w, http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_020519befed9464785ff686dfd9be1d1-850x253.png 850w, http:\/\/viplao.com\/wp-content\/uploads\/2023\/06\/gfbp4bwpctdbo_20230620_020519befed9464785ff686dfd9be1d1.png 1500w\" sizes=\"(max-width: 1024px) 100vw, 1024px\" \/><\/figure>\n\n\n\n<ol>\n<li>\u6700\u540e\uff0c\u6211\u4eec\u5c06\u8fd9\u4e9b\u5b9e\u65f6\u7684\u7edf\u8ba1\u6570\u636e\u5199\u56de\u6570\u636e\u5e93\uff0cFlink SQL \u4e5f\u53ef\u4ee5\u7b80\u5355\u5730\u5b9e\u73b0\u8fd9\u4e00\u70b9\u3002\u9996\u5148\u6211\u4eec\u9700\u8981\u521b\u5efa\u4e00\u5f20\u7528\u4e8e\u8fde\u63a5\u6c47\u8868\u7684 Flink \u4e34\u65f6\u8868\uff0c\u5982\u4e0b\u6240\u793a\uff1a<\/li>\n<\/ol>\n\n\n\n<pre class=\"wp-block-code\"><code>CREATE TEMPORARY TABLE sink_table (\n    record_timestamp TIMESTAMP(3) NOT NULL PRIMARY KEY NOT ENFORCED,\n    good_name VARCHAR(128),\n    sell_amount INT\n) WITH (\n  'connector' = 'jdbc',\n  'url' = 'jdbc:mysql:\/\/******************.mysql.rds.aliyuncs.com:3306\/***********',\n  'table-name' = 'sink_table',\n  'username' = '***********',\n  'password' = '***********',\n  'scan.auto-commit' = 'true'\n);\n<\/code><\/pre>\n\n\n\n<p>\u7136\u540e\uff0c\u53ea\u9700\u8981\u5c06\u4e0a\u9762\u7684 SELECT \u8bed\u53e5\u7684\u8f93\u51fa\u7ed3\u679c INSERT \u5230\u8be5\u8868\u5c31\u53ef\u4ee5\u4e86\uff1a<\/p>\n\n\n\n<pre class=\"wp-block-code\"><code>INSERT INTO sink_table \nSELECT \n  record_timestamp, \n  <em>-- ... \u548c\u4e0a\u9762\u7684\u8bed\u53e5\u4e00\u6837<\/em>\n<\/code><\/pre>\n\n\n\n<p>\u73b0\u5728\uff0c\u70b9\u51fb\u63a7\u5236\u53f0\u4e0a\u7684\u300c\u4e0a\u7ebf\u300d\u6309\u94ae\uff0c\u5373\u53ef\u5c06\u6211\u4eec\u7f16\u5199\u7684 Flink SQL \u4f5c\u4e1a\u90e8\u7f72\u4e0a\u7ebf\u6267\u884c\u3002\u60a8\u53ef\u4ee5\u4f7f\u7528\u6570\u636e\u5e93\u5ba2\u6237\u7aef\u7b49\u8f6f\u4ef6\u89c2\u5bdf\u6c47\u8868\u4e2d\u662f\u5426\u5199\u5165\u4e86\u6b63\u786e\u7684\u6570\u636e\u3002<\/p>\n\n\n\n<blockquote class=\"wp-block-quote\">\n<p>\u963f\u91cc\u4e91\u5b9e\u65f6\u8ba1\u7b97\u63a7\u5236\u53f0\u5728\u4f7f\u7528\u300c\u6267\u884c\u300d\u529f\u80fd\u8c03\u8bd5\u65f6\uff0c\u4e0d\u4f1a\u5199\u5165\u4efb\u4f55\u6570\u636e\u5230\u4e0b\u6e38\u4e2d\u3002\u56e0\u6b64\u4e3a\u4e86\u6d4b\u8bd5\u4f7f\u7528 SQL Connector \u5199\u5165\u6c47\u8868\uff0c\u60a8\u5fc5\u987b\u4f7f\u7528\u300c\u4e0a\u7ebf\u300d\u529f\u80fd\u3002<\/p>\n<\/blockquote>\n\n\n\n<p>\u60a8\u4e5f\u53ef\u4ee5\u8fdb\u5165 Flink UI \u63a7\u5236\u53f0\u89c2\u5bdf\u6d41\u6570\u636e\u5904\u7406\u56fe\u3002\u5728\u8fd9\u4e2a\u7b80\u5355\u7684\u793a\u4f8b\u4e2d\uff0c\u9996\u5148\u8fdb\u884c\u7684\u662f\u6e90\u8868\u6570\u636e\u7684\u6355\u83b7\u4e0e\u7a97\u53e3\u805a\u5408\uff1b\u63a5\u7740\u548c\u7ef4\u5ea6\u8868\u8fdb\u884c JOIN \u64cd\u4f5c\u5f97\u5230\u8fd0\u7b97\u7ed3\u679c\uff1b\u6700\u540e\u5c06\u5904\u7406\u6570\u636e\u5b58\u5165\u6c47\u8868\u3002<\/p>\n\n\n\n<p><a href=\"https:\/\/developer.aliyun.com\/article\/1257268?ex=bigdata\">\u5982\u4f55\u5b9e\u65f6\u7edf\u8ba1\u6700\u8fd1 15 \u79d2\u7684\u5546\u54c1\u9500\u552e\u989d\uff5cFlink-Learning \u5b9e\u6218\u8425-\u963f\u91cc\u4e91\u5f00\u53d1\u8005\u793e\u533a (aliyun.com)<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"<p>\u60f3\u8981\u4e86\u89e3\u5982\u4f55\u4f7f\u7528 Flink \u5b9e\u65f6\u7edf\u8ba1\u6700\u8fd1 15 \u79d2\u7684\u5546\u54c1\u9500\u552e\u989d\u5417\uff1f\u672c\u5b9e\u9a8c\u5c06\u4ee5\u963f\u91cc\u4e91\u5b9e\u65f6\u8ba1\u7b97 Fli&hellip; <a href=\"http:\/\/viplao.com\/index.php\/2023\/06\/21\/flinksql%e5%ae%9e%e8%b7%b5-%e5%a6%82%e4%bd%95%e5%ae%9e%e6%97%b6%e7%bb%9f%e8%ae%a1%e6%9c%80%e8%bf%91-15-%e7%a7%92%e7%9a%84%e5%95%86%e5%93%81%e9%94%80%e5%94%ae%e9%a2%9d\/\" class=\"more-link read-more\" rel=\"bookmark\">\u7ee7\u7eed\u9605\u8bfb <span class=\"screen-reader-text\">flinkSQL\u5b9e\u8df5 &#8211; \u5982\u4f55\u5b9e\u65f6\u7edf\u8ba1\u6700\u8fd1 15 \u79d2\u7684\u5546\u54c1\u9500\u552e\u989d<\/span><i class=\"fa fa-arrow-right\"><\/i><\/a><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":[],"categories":[1],"tags":[25],"views":628,"_links":{"self":[{"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/posts\/2012"}],"collection":[{"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/comments?post=2012"}],"version-history":[{"count":3,"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/posts\/2012\/revisions"}],"predecessor-version":[{"id":2026,"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/posts\/2012\/revisions\/2026"}],"wp:attachment":[{"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/media?parent=2012"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/categories?post=2012"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/viplao.com\/index.php\/wp-json\/wp\/v2\/tags?post=2012"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}