原創(chuàng)|行業(yè)資訊|編輯:陳俊吉|2016-09-27 10:47:49.000|閱讀 526 次
概述:現(xiàn)在,讓我們一起來(lái)了解Streams V4.2新特性之一:支持使用 Python 開(kāi)發(fā) Streams 應(yīng)用程序。
# 界面/圖表報(bào)表/文檔/IDE等千款熱門(mén)軟控件火熱銷售中 >>
相關(guān)鏈接:
上周我們介紹了Streams V4.2即將eGA的消息和該版本的主要特性。目前Streams V4.2以及正式eGA,感興趣的伙伴們請(qǐng)?jiān)L問(wèn)IBM Knowledge Center(//www.ibm.com/support/knowledgecenter/zh/SSCRJU_4.2.0/com.ibm.streams.welcome.doc/doc/kc-homepage.html)獲取更多信息并下載試用。
現(xiàn)在,讓我們一起來(lái)了解Streams V4.2新特性之一:支持使用 Python 開(kāi)發(fā) Streams 應(yīng)用程序。
Topology Toolkit允許流應(yīng)用程序員使用SPL(Streams Processing Language)之外,更常見(jiàn)、更熟悉的語(yǔ)言開(kāi)發(fā)流應(yīng)用程序。該Toolkit支持多種編程語(yǔ)言,包括Java、Scala,以及V4.2新增對(duì)Python的支持。
Python 是一種常見(jiàn)的語(yǔ)言,具有大型、全面的標(biāo)準(zhǔn)庫(kù)以及多個(gè)第三方庫(kù)。使用新的 IBM Streams Python 應(yīng)用程序 API(包含在 Topology Toolkit 中),可通過(guò)Python 可調(diào)用類或函數(shù)創(chuàng)建流處理應(yīng)用程序。這意味著程序員可以利用整個(gè)Python庫(kù)的優(yōu)勢(shì),解決他們的業(yè)務(wù)問(wèn)題。
使用Python定義流應(yīng)用程序的結(jié)構(gòu)
在流數(shù)據(jù)中將Python對(duì)象作為元組進(jìn)行傳遞
定義流數(shù)據(jù)如何以一個(gè)模塊化,可擴(kuò)展和有狀態(tài)的方式被處理
正如下面的API函數(shù)列表,程序員可以使用很多Python的函數(shù)。例如,您可以使用transform和map對(duì)數(shù)據(jù)進(jìn)行操作。
Jupyter Notebook 和 Python
既然我們能夠利用Python應(yīng)用程序 API開(kāi)發(fā),那我們就可以使用Jupyter Notebook編寫(xiě)代碼,并編譯和執(zhí)行,以及查看運(yùn)行結(jié)果。
下圖在Jupyter演示一片簡(jiǎn)單的代碼,它從一個(gè)數(shù)據(jù)源讀取一些數(shù)據(jù),然后創(chuàng)建一個(gè)輸出視圖并在Jupyter顯示。該應(yīng)用程序被編譯并以集群方式運(yùn)行,然后使用matplotlib來(lái)顯示是每秒刷新結(jié)果的曲線圖。
關(guān)于Jupyter的介紹請(qǐng)參考另一篇文章《在Jupyter Notebooks里進(jìn)行,So easy!》。
使用 Python 開(kāi)發(fā)Streams 應(yīng)用程序入門(mén)指導(dǎo) Python應(yīng)用程序API是開(kāi)源的,您可以在GitHub上的streamsx.topology項(xiàng)目找到更多的說(shuō)明。您也可以從下面的鏈接里獲取相關(guān)入門(mén)指導(dǎo)。 //ibmstreams.github.io/streamsx.documentation/docs/latest/python/python-appapi-devguide/
詳情請(qǐng)咨詢!
客服熱線:023-66090381
本站文章除注明轉(zhuǎn)載外,均為本站原創(chuàng)或翻譯。歡迎任何形式的轉(zhuǎn)載,但請(qǐng)務(wù)必注明出處、不得修改原文相關(guān)鏈接,如果存在內(nèi)容上的異議請(qǐng)郵件反饋至chenjj@fc6vip.cn