本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

# 執行串流資料的互動式分析
<a name="how-zeppelin-interactive"></a>

您使用由 Apache Zeppelin 提供支援的無伺服器筆記本與串流資料互動。您的筆記本可以包含多條筆記，每條筆記可以有一個或多個段落，可以在其中撰寫程式碼。

下列範例 SQL 查詢顯示如何從資料來源擷取資料：

```
%flink.ssql(type=update)
select * from stock;
```

如需 Flink 串流 SQL 查詢的更多範例，請參閱 Apache Flink 文件中的[Managed Service for Apache Flink 中 Studio 筆記本的範例和教學課程](how-zeppelin-examples.md)以下內容和[查詢](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/table/sql/queries/overview/)。

您可以在 Studio 筆記本中使用 Flink SQL 查詢來查詢串流資料。也可以使用 Python (資料表 API) 和 Scala (資料表和 Datastream API) 編寫程式，以互動方式查詢串流資料。您可以檢視查詢或程式的結果，在幾秒鐘內更新它們，然後重執行以檢視更新的結果。

## Flink 解譯器
<a name="how-zeppelin-interactive-interpreters"></a>

您可以使用*解譯器*指定 Managed Service for Apache Flink 用來執行應用程式的語言。您可以將下列解譯器用於 Managed Service for Apache Flink：


| 名稱 | 類別 | Description | 
| --- |--- |--- |
| %flink | FlinkInterpreter | Creates ExecutionEnvironment/StreamExecutionEnvironment/BatchTableEnvironment/StreamTableEnvironment and provides a Scala environment | 
| %flink.pyflink | PyFlinkInterpreter | Provides a python environment | 
| %flink.ipyflink | IPyFlinkInterpreter | Provides an ipython environment | 
| %flink.ssql | FlinkStreamSqlInterpreter | Provides a stream sql environment | 
| %flink.bsql | FlinkBatchSqlInterpreter | Provides a batch sql environment | 

如需 Flink 解譯器的詳細資訊，請參閱 [Apache Zeppelin 的 Flink 解譯器](https://zeppelin.apache.org/docs/0.9.0/interpreter/flink.html)。

如果您使用 `%flink.pyflink` 或 `%flink.ipyflink` 作為解譯器，則需要使用 `ZeppelinContext` 來視覺化筆記本內的結果。

如需更多的 PyFlink 具體範例，請參閱[使用適用於 Studio 和 Python 的 Managed Service for Apache Flink 以互動方式查詢資料串流](https://aws.amazon.com/blogs/big-data/query-your-data-streams-interactively-using-kinesis-data-analytics-studio-and-python/)。

## Apache Flink 資料表環境變數
<a name="how-zeppelin-interactive-env-vars"></a>

Apache Zeppelin 使用環境變數提供對資料表環境資源的存取。

您可以使用以下變數存取 Scala 資料表環境資源：


| 變數 | 資源 | 
| --- |--- |
| senv | StreamExecutionEnvironment | 
| stenv | Blink 規劃器的 StreamTableEnvironment | 

您可以使用以下變數存取 Python 資料表環境資源：


| 變數 | 資源 | 
| --- |--- |
| s\$1env | StreamExecutionEnvironment | 
| st\$1env | Blink 規劃器的 StreamTableEnvironment | 

如需使用資料表環境的詳細資訊，請參閱 Apache Flink 文件中的[概念和常見 API](https://nightlies.apache.org/flink/flink-docs-release-1.19/docs/dev/table/common/)。