我們接下來看看如何使用交互式會(huì)話。

創(chuàng)建交互式會(huì)話

POST /sessions

使用交互式會(huì)話的前提是需要先創(chuàng)建會(huì)話。當(dāng)我們提交請求創(chuàng)建交互式會(huì)話時(shí)，我們需要指定會(huì)話的類型（“kind”），比如“spark”，Livy會(huì)根據(jù)我們所指定的類型來啟動(dòng)相應(yīng)的REPL，當(dāng)前Livy可支持spark、pyspark或是sparkr三種不同的交互式會(huì)話類型以滿足不同語言的需求。

當(dāng)創(chuàng)建完會(huì)話后，Livy會(huì)返回給我們一個(gè)JSON格式的數(shù)據(jù)結(jié)構(gòu)表示當(dāng)前會(huì)話的所有信息：



其中需要我們關(guān)注的是會(huì)話id，id代表了此會(huì)話，所有基于該會(huì)話的操作都需要指明其id。

提交代碼

POST /sessions/{sessionId}/statements

創(chuàng)建完交互式會(huì)話后我們就可以提交代碼到該會(huì)話上去執(zhí)行。與創(chuàng)建會(huì)話相同的是，提交代碼同樣會(huì)返回給我們一個(gè)id用來標(biāo)識(shí)該次請求，我們可以用id來查詢該段代碼執(zhí)行的結(jié)果。

查詢執(zhí)行結(jié)果

GET /sessions/{sessionId}/statements/{statementId}


Livy的REST API設(shè)計(jì)為非阻塞的方式，當(dāng)提交代碼請求后Livy會(huì)立即返回該請求id而并非阻塞在該次請求上直到執(zhí)行完成，因此用戶可以使用該id來反復(fù)輪詢結(jié)果，當(dāng)然只有當(dāng)該段代碼執(zhí)行完畢后用戶的查詢請求才能得到正確結(jié)果。

當(dāng)然Livy交互式會(huì)話還提供許多不同的REST API來操作會(huì)話和代碼，在這就不一一贅述了。


深圳市云網(wǎng)數(shù)據(jù)中心(sjsyph.cn)
專業(yè)提供【服務(wù)器租用】【服務(wù)器托管】【機(jī)柜大帶寬】【云主機(jī)租用】【CDN加速】【專線接入】