Streams V4.2新特性：支持使用 Python 開發(fā) Streams 應用程序

---

上周我們介紹了Streams V4.2即將eGA的消息和該版本的主要特性。目前Streams V4.2以及正式eGA，感興趣的伙伴們請訪問IBM Knowledge Center（http://www.ibm.com/support/knowledgecenter/zh/SSCRJU_4.2.0/com.ibm.streams.welcome.doc/doc/kc-homepage.html）獲取更多信息并下載試用。

現(xiàn)在，讓我們一起來了解Streams V4.2新特性之一：支持使用 Python 開發(fā) Streams 應用程序。

支持Python讓流應用開發(fā)者有更多的語言選擇

Topology Toolkit允許流應用程序員使用SPL（Streams Processing Language）之外，更常見、更熟悉的語言開發(fā)流應用程序。該Toolkit支持多種編程語言，包括Java、Scala，以及V4.2新增對Python的支持。

Python 是一種常見的語言，具有大型、全面的標準庫以及多個第三方庫。使用新的 IBM Streams Python 應用程序 API（包含在 Topology Toolkit 中）,可通過Python 可調(diào)用類或函數(shù)創(chuàng)建流處理應用程序。這意味著程序員可以利用整個Python庫的優(yōu)勢，解決他們的業(yè)務問題。

使用Python應用程序API，您可以：

使用Python定義流應用程序的結(jié)構(gòu)

在流數(shù)據(jù)中將Python對象作為元組進行傳遞

定義流數(shù)據(jù)如何以一個模塊化，可擴展和有狀態(tài)的方式被處理

Python 應用程序 API 函數(shù)作為Streams的Operator

正如下面的API函數(shù)列表，程序員可以使用很多Python的函數(shù)。例如，您可以使用transform和map對數(shù)據(jù)進行操作。

Jupyter Notebook 和 Python

既然我們能夠利用Python應用程序 API開發(fā)流應用程序，那我們就可以使用Jupyter Notebook編寫代碼，并編譯和執(zhí)行，以及查看運行結(jié)果。

下圖在Jupyter演示一片簡單的代碼，它從一個數(shù)據(jù)源讀取一些數(shù)據(jù)，然后創(chuàng)建一個輸出視圖并在Jupyter顯示。該應用程序被編譯并以集群方式運行，然后使用matplotlib來顯示是每秒刷新結(jié)果的曲線圖。

關于Jupyter的介紹請參考另一篇文章《在Jupyter Notebooks里進行大數(shù)據(jù)分析，So easy！》。

使用 Python 開發(fā)Streams 應用程序入門指導 Python應用程序API是開源的，您可以在GitHub上的streamsx.topology項目找到更多的說明。您也可以從下面的鏈接里獲取相關入門指導。 http://ibmstreams.github.io/streamsx.documentation/docs/latest/python/python-appapi-devguide/

更多大數(shù)據(jù)與分析相關行業(yè)資訊、解決方案、案例、教程等請點擊查看>>>

詳情請咨詢在線客服！

客服熱線：023-66090381