¸üÐÂʱ¼ä:2022Äê10ÔÂ11ÈÕ10ʱ08·Ö À´Ô´:ÀÖÓãµç¾º ä¯ÀÀ´ÎÊý:
¡¡¡¡7ÔÂ29ÈÕ-31ÈÕ,ApacheCon Asia 2022¿ªÔ´´ó»áÔÚÏßÉÏÊ¢´ó¿ªÆô,À´×ÔÀÖÓãµç¾ºPython+´óÊý¾Ýѧ¿ÆµÄÕž´´æÀÏʦ¡¢ÕÔ³¿½ÜÀÏʦ,¹²Í¬ÔÚ»áÉÏ·¢±íÁËÌâΪ¡¶´óÊý¾Ý&PythonÉú̬ÔÚÀÖÓãµç¾ºµÄʵ¼ùºÍ˼¿¼¡·µÄÑݽ²,ºÍÓë»áÕß·ÖÏíÁËÀÖÓãµç¾º¶Ô´óÊý¾Ý&PythonÉú̬·¢Õ¹µÄ˼¿¼¡¢Ì½Ë÷Óëʵ¼ùÀú³Ì¡£
¡¡¡¡¾ÝϤ,ApacheCon Asia 2022ÊÇÓÉApache Èí¼þ»ù½ð»á(ASF)×éÖ¯µÄ¹Ù·½È«ÇòϵÁдó»á,×÷Ϊ¾Ã¸ºÊ¢ÃûµÄ¿ªÔ´Ê¢Ñç,»î¶¯ÎüÒýÁËÈ«ÇòµÄ¿ª·¢ÕßǰÀ´Ì½ÌÖ¿ªÔ´¼¼Êõ¡¢¿ªÔ´ÎÄ»¯ºÍ¿ªÔ´ÀíÄî¡£

¡¡¡¡½ñÄêµÄApacheCon Asia 2022»áÒéÒé³Ì¸²¸ÇÁËÊýÊ®¸öÀà±ðµÄApache ÏîÄ¿ÄÚÈÝ,´ÓÁ÷´¦Àíµ½ÏûÏ¢¶ÓÁС¢¼¯³É,´Ó´óÊý¾Ýµ½½ðÈڿƼ¼,´ÓËÑË÷ÔÙµ½TomcatµÈ¶¼ÓÐÉæ¼°¡£
¡¡¡¡µ±Ç°,´óÊý¾Ý¼¼ÊõÕýÔÚÉî¿ÌµÄÒýÁìºÍ¸Ä±äן÷¸öÐÐÒµ·¢Õ¹,¶øApache Èí¼þ»ù½ð»á(ASF)ÓÐ×ŷdz£¶àµÄ´óÊý¾ÝÏîÄ¿,±ÈÈçHadoop, Hive, Spark, HBase, Kylin, Ozone, CarbonData, Doris, Cassandra, ZooKeeper,Hudi,Iceberg,Zeppelin,SeaTunnel(incubator) µÈ¡£Ò²Òò´Ë,±¾´Î´óÊý¾Ý·ÖÂÛ̳±¶ÊÜÒµÄÚ¹Ø×¢¡£Ôڻ᳡ÖÐ,¿ª·¢ÕßÃǹ²Í¬Ì½ÌÖ´óÊý¾ÝµÄÇ°ÑØ¼¼ÊõÇ÷ÊÆÒÔ¼°Ò»ÏßÓû§µÄʵ¼ù¾Ñé¡¢ÔÀí¡¢¼Ü¹¹·ÖÎöµÈ¡£
¡¡¡¡ÀÖÓãµç¾ºÁ½Î»ÀÏʦ×÷Ϊ´óÊý¾ÝÁìÓòµÄ̽Ë÷ÕߺÍÊÚÒµÕß,ÊÜÑû·ÖÏíÁË¡¶´óÊý¾Ý Python&Éú̬ÔÚÀÖÓãµç¾ºµÄʵ¼ùºÍ˼¿¼¡·,²¢´Ó´óÊý¾ÝPythonÉú̬·¢Õ¹¡¢ÀÖÓãµç¾º»ùÓÚ´óÊý¾ÝPythonÉú̬¼Ü¹¹Ñݱä¹ý³Ì¡¢´óÊý¾ÝPythonÉú̬ÔÚÀÖÓãµç¾ºÂäµØÊµ¼ù¡¢ÀÖÓãµç¾º´óÊý¾ÝPythonÉú̬µÄÕ¹ÍûËĸö·½Ãæ,Éî¶È½âÎöÁËÀÖÓãµç¾º³¤ÆÚÒÔÀ´¶Ô´óÊý¾ÝPythonµÄ¼¼ÊõÀíÄʵ¼ùÓ¦Óúͷ¢Õ¹¡£
´óÊý¾ÝPythonÉú̬·¢Õ¹
¡¡¡¡ÀÖÓãµç¾ºÈÏΪ,´óÊý¾ÝPythonÉú̬µÄºËÐÄÄ¿±êʵ¼ÊÉÏÎ§ÈÆ×ÅÁ½¸ö¹Ø¼ü×Ö,·Ö±ðÊÇ´óÊý¾ÝºÍPython¡£
¡¡¡¡¾ßÌåÀ´½²ÎÞ·ÇÁ½µã,µÚÒ»Êǽ«´óÊý¾ÝµÄÄÜÁ¦Êä³ö¸øPythonÓû§,±ÈÈç˵Pyspark, ¾ÍÏ൱ÓÚ½«sparkµÄ¼ÆËãÄÜÁ¦Êä³ö¸øÁËPythonÓû§,½ø¶ø¾ÍÓÐÁËPysparkÕâÖÖ×é¼þ¡£
¡¡¡¡Æä´ÎÒª½«PythonÉú̬·ÖÎö¼ÆËãµÄ¹¦ÄÜÔËÐе½´óÊý¾ÝµÄ×齨ÉÏ,½ø¶øÌáÉýPythonÉú̬¶Ô´óÊý¾ÝÎÊÌâµÄ½â¾öÄÜÁ¦¡£

¡¡¡¡´ËÍâ,ʹÓÃPythonÓïÑÔÀ´Ñ§Ï°ºÍÓ¦ÓôóÊý¾ÝÊǷdz£¾ßÓÐÓÅÊÆµÄ,´óÊý¾ÝÃ÷ÐÇ¿ò¼ÜSparkÊ×ÍÆÊ¹ÓÃPythonÓïÑÔ½øÐпª·¢¡£
·
ÀÖÓãµç¾º»ùÓÚ´óÊý¾ÝPythonÉú̬¼Ü¹¹Ñݱä¹ý³Ì
¡¡¡¡| ÀÖÓãµç¾º»ùÓÚ´óÊý¾ÝPythonÉú̬¼Ü¹¹Ñݱä¹ý³Ì
¡¡¡¡ÕÔÀÏʦ½áºÏÀÖÓãµç¾ºµÄʵ¼ÊÇé¿ö¾ÙÀý˵,ÀÖÓãµç¾ºµÄÏßÉÏÆ½Ì¨ÒµÎñÏßÉæ¼°100¶à¸öÒµÎñµÄ¿´°å,3000¶à¸öÒµÎñÖ¸±êµÄ·ÖÎö,¶ÔÓÚÈç´ËÅÓ´óµÄÒµÎñ´¦Àí,ÀÖÓãµç¾º²ÉÓÃÁËPython+´óÊý¾ÝÉú̬,´Ó¶øÊµÏÖÕû¸öÊý¾ÝµÄPipelineÀ´²Ù×÷,ͬʱͨ¹ýʵʱÊý²Ö¡¢Óû§»ÏñºÍÍÆ¼öϵͳµÈ¸üºÃµØÎªÓû§ÌṩºÏÊʵIJúÆ·¡£
¡¡¡¡Êµ¼ÊÒµÎñÖÐÓöµ½ºÜ¶àÀ§ÄÑ,±ÈÈç:Óû§×ÉѯºÍѧϰÐÐΪµÄ´ó·ùÉÏÕÇ;¸÷ÒµÎñ¿âºÍµÚÈý·½ÏµÍ³µÄÊý¾Ýͬ²½,²É¼¯Í¬²½;ÒµÎñ·ÖÎöÀàÐèÇó²éѯЧÂʵÍ(ʹÓ÷ÖÎö¿âADB²éѯЧÂÊÈÔÈ»µÍÏÂ);ÖÇÄÜÍÆ¼ö(Õë¶Ô¸öÐÔ»¯ÐÐΪÐÅÏ¢,ÈçºÎʵÏÖ¸öÐÔ»¯¿Î³ÌÍÆ¼ö)µÈ¡£
¡¡¡¡ÀÖÓãµç¾º»ùÓÚÉÏÊöÍ´µãÉý¼¶Á˼ܹ¹,²ÉÓÃPyflinkÉú̬,ÖØÐÂÉè¼Æ³öÊʺÏÒµÎñ´óÊý¾ÝµÄÒ»¸ö¼¼Êõ¼Ü¹¹,ÔËÓôóÊý¾ÝPythonÉú̬µÄPyflinkʵÏÖETL´¦Àí,ʵʱÊý²Ö,ʵÏÖÓû§»ÏñºÍÍÆ¼öµÈ¡£

¡¡¡¡ÖµµÃÒ»ÌáµÄÊÇ,ÉÏͼËùʾµÄ¼Ü¹¹±äǨV3.0ÖÐ,´ÓʵʱÊý²Ö¡¢»Ïñµ½ÍƼöϵͳ,¶¼ÔÚÕû¸öÀÖÓãµç¾ºµÄ´óÊý¾Ýƽ̨,²¢Ê×´ÎÒýÈë PyFlink,µ«ÊÇÔÚʹÓùý³ÌÖÐÓÉÓÚÓöµ½Á˺ܶര¿ÚµÄ²Ù×÷²»Ö§³ÖÎÊÌâ,ÇÒµ±Ê±PyFlink±¾Éí¹¦Äܲ»ÍêÉÆ,ËùÒÔÀÖÓãµç¾º¾Í¿ª·¢ÁË´°¿Ú¼°ÆäËûPyFLinkËã×ÓÏà¹Ø¹¦ÄÜ,²¢¹±Ï×ÁËÊ®¶à¸ö PR À´°ïÖú PyFlink ±äµÃ¸ü¼Ó³ÉÊì¡£
´óÊý¾ÝPythonÉú̬ÔÚÀÖÓãµç¾ºÂäµØÊµ¼ù
¡¡¡¡ÀÖÓãµç¾ºÔÚÏßÉÏÆ½Ì¨ÓµÓжà¸öѧ¿Æ,30¶à¸ö¾Íҵģ¿é¿Î³Ì,ÉϰÙÃÅС¿Î,ÐèÒª¸ù¾ÝÓû§ÐÐÎªÊµÊ±ÍÆ¼öС¿ÎºÍ¾ÍÒµ°à¿Î³Ì,Éæ¼°Ê×Ò³ÍÆ¼ö¡¢ÈÈÃÅÍÆ¼ö¡¢²ÂÄãϲ»¶¡¢ËÑË÷Ò³ºÃ¿ÎÍÆ¼öµÈ,ÐèҪͨ¹ýÓû§»ÏñºÍÍÆ¼öϵͳÍê³É¸öÐÔ»¯ÍƼö·þÎñ¡£

¡¡¡¡ÒÔÓû§»ÏñÂäµØÊµ¼ùΪÀý,Óû§ÐÅÏ¢±êÇ©»¯,Ò²¾ÍÊdzéÈ¡³öÒ»¸öƽ̨Óû§µÄÐÅϢȫò,´Ó¶ø½â¾öÈçºÎ½«Êý¾Ýת»¯ÎªÉÌÒµ¼ÛÖµµÄÎÊÌâ,°üÀ¨½ÌÓý³Ì¶È¡¢Ö°Òµ¡¢Ï²ºÃµÈ±êÇ©,ÒÔ±ãÈ«ÃæÁ˽âÓû§ÐÅÏ¢,ͬʱ¸øÍƼöϵͳÌṩÊý¾ÝÖ§³Ö¡£
¡¡¡¡ÄǸÃʹÓÃʲô¼¼ÊõÍê³É±êÇ©¼ÆËã?

¡¡¡¡ÔÚÀÖÓãµç¾º´óÊý¾Ý&PythonÉú̬ÖÐ,»áÊ×ÏȽ«±êÇ©½øÐзּ¶,ʹÓÃPyFlink¼¼ÊõÕ»Íê³ÉÈË¿ÚÊôÐÔÏÂÃæµÄÄêÁä¡¢ÐÔ±ðµÈËļ¶±êÇ©¼Æ;ÉÌÒµÊôÐÔÖÐÖ§¸¶·½Ê½¡¢¿Íµ¥¼Û¡¢ÓÐȯ±ØÂòµÈËļ¶±êÇ©;ÐÐΪÊôÐÔÖÐä¯ÀÀʱ³¤¡¢µÇ¼ƵÂÊ¡¢·ÃÎÊÆµÂʵÈËļ¶±êÇ©¡£
¡¡¡¡È»ºó,ͨ¹ýPyFlinkºÍPyAlinkÕûºÏÍê³É¿Í»§¼ÛÖµ±êÇ©RFM¡¢Óû§»îÔ¾¶ÈÄ£ÐÍRFE¡¢¼ÛÖµÃô¸Ð¶ÈÄ£ÐÍPSM¡¢¹ºÂòÐÔ±ð±êÇ©USGµÈ,´Ó¶øÍê³ÉÓû§»ÏñµÄ×Éѯ,ÒÔ¼°ºóÐø¿Î³Ì¡¢¾ÍÒµ¡¢³öÇÚµÈ10¶à¸ö¿´°å,1000¶à¸öËļ¶±êÇ©¹¹½¨¡£
Õ¹ÍûÀÖÓãµç¾º´óÊý¾ÝPythonÉú̬
¡¡¡¡×îºó,ÀÖÓãµç¾ºµÄÕÔ³¿½ÜÀÏʦ,·ÖÏíÁË´óÊý¾ÝPythonÉú̬ÔÚÀÖÓãµç¾ºµÄδÀ´·¢Õ¹Õ¹Íû¡£

¡¡¡¡ÀýÈç,ÔÚʵʱÊý²Ö·½Ãæ,½«½èÖúÓÚPython´óÊý¾ÝÉú̬Íê³É ,Êý¾Ýºþʵʱ½ÓÈëÊý¾Ý,Dorisʵʱͬ²½Êý¾ÝºþÊý¾Ý¡£
¡¡¡¡ÔÚÓû§»Ïñ·½Ãæ,ÍêÉÆÓû§±êÇ©Ìåϵ,Ôö¼ÓÍÚ¾òÀà±êǩռ±È,·á¸»ÊµÊ±Óû§»Ïñ³¡¾°µÈ¡£
¡¡¡¡ÔÚÍÆ¼öϵͳ·½Ãæ,Ôö¼Ó֪ʶͼÆ×ÍÆ¼ö,½áºÏÇ¿»¯Ñ§Ï°ÊµÏÖ¾«×¼ÍƼö,Ô¤ÑÐBertÄ£ÐÍÔÚÍÆ¼öϵͳӦÓõȡ£
¡¡¡¡ÀÖÓãµç¾ºÏàÐÅÔÚApache ¸÷À࿪Դ¿ò¼ÜµÄÓ¦ÓÃÏÂ,ÀÖÓãµç¾ºµÄ¸÷ÀàϵͳӦÓÃÄÜÔ½À´Ô½ºÃ,ͬʱÔÚʵ¼ùµÄ¹ý³ÌÖÐ,Ò²ÄÜ·´²¸ÏµÍ³¹¦ÄÜ,Èÿò¼Ü¸üÍêÕû,ʵÏÖ¸ü¶àµÄ¹¦ÄÜ¡£
¡¡¡¡ÎªÁËÈøü¶àµÄ¿ª·¢ÕßÔÚApacheÉçÇøÑ§µ½´óÊý¾ÝÏà¹ØµÄÇ°ÑØ¼¼Êõ,ÀÖÓãµç¾ºÏÖÒÑÁªºÏApache Hudi¡¢Apache Doris¡¢Apache Pulsar µÈ¹Ù·½ÉçÇøÍÆ³öÁËÍêÕûµÄÖÐÎĿγÌ,¸øÏëÒªÁ˽âºÍʹÓÃÕâЩ¼¼ÊõµÄͬѧ,Ìṩһ¸ö¿ìËÙÈëÃŵÄ;¾¶,ҲΪ¿ªÔ´ÉçÇø¹±Ï×ÁË×Ô¼ºµÄÒ»·ÝÁ¦Á¿¡£
¡¡¡¡ÀÖÓãµç¾º´Ë´ÎÓ¦Ñû³öϯApacheCon Asia 2022¿ªÔ´´ó»á,Õ¹ÏÖ³ö¸ßм¼Êõ¿ª·¢¼°Ó¦ÓõÄʵÁ¦,×÷ΪһֱÖÂÁ¦ÓÚÅàÑøÊý×Ö»¯È˲ŵÄÖ°Òµ½ÌÓý¼¯ÍÅ,δÀ´½«¼ÌÐøÉî¸ûм¼Êõ³¡¾°»¯Ó¦Óã¬Ì½Ë÷Êý×Ö»¯È˲ÅÅàÑøÄ£Ê½£¬´ø¸øÐÐÒµ¸ü¶àÇ°ÑØÌ½Ë÷ʵ¼ù¡£
±±¾©Ð£Çø