Skip to content

Commit

Permalink
Copy Files From Source Repo (2024-08-09 19:56)
Browse files Browse the repository at this point in the history
  • Loading branch information
olprod committed Aug 10, 2024
1 parent 1a5083b commit 453f8b6
Showing 1 changed file with 28 additions and 27 deletions.
55 changes: 28 additions & 27 deletions Instructions/Labs/09-real-time-analytics-eventstream.md
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,7 @@ lab:
1. 你将可以选择为数据库命名,然后选择“新数据库(默认)”或创建“新快捷方式数据库(后继)”********
1. 选择**创建**

>[!Note]
> 使用后继数据库功能可将另一群集中的数据库附加到 Azure 数据资源管理器群集。 后继数据库以只读模式附加,因此可以查看其数据,并针对已引入先导数据库的数据运行查询。 后继数据库会同步先导数据库中的更改。 由于同步的缘故,数据可用性方面会存在几秒钟到几分钟的数据延迟。 具体的延迟时长取决于先导数据库元数据的总体大小。 先导数据库和后继数据库使用相同的存储帐户来提取数据。 存储由先导数据库拥有。 后继数据库无需引入数据即可查看数据。 由于附加的数据库是只读的数据库,因此无法修改数据库中除缓存策略、主体和权限以外的其他数据、表和策略。
>**注意:** 使用后继数据库功能可将另一群集中的数据库附加到 Azure 数据资源管理器群集。 后继数据库以只读模式附加,因此可以查看其数据,并针对已引入先导数据库的数据运行查询。 后继数据库会同步先导数据库中的更改。 由于同步的缘故,数据可用性方面会存在几秒钟到几分钟的数据延迟。 具体的延迟时长取决于先导数据库元数据的总体大小。 先导数据库和后继数据库使用相同的存储帐户来提取数据。 存储由先导数据库拥有。 后继数据库无需引入数据即可查看数据。 由于附加的数据库是只读的数据库,因此无法修改数据库中除缓存策略、主体和权限以外的其他数据、表和策略。
![选择 kqldatabase 的图像](./Images/create-kql-database-eventhouse.png)

Expand All @@ -75,36 +74,32 @@ lab:
## 创建 Eventstream

1. 在菜单栏中,选择“实时智能”(该图标类似于“实时智能徽标”![](./Images/rta_logo.png)****
2. 在“新建”下,选择“EventStream (预览)”
2. 在“**新建**”下,选择“**Eventstream**”。

![选择事件流的图像](./Images/select-eventstream.png)

3. 系统会提示为 Eventstream 命名。 为 EventStream 指定一个你能记住的名称(如 MyStockES),然后按“创建”按钮********
3. 系统会提示为 Eventstream 命名。 为 EventStream 指定一个你能记住的名称,例如 **MyStockES**,然后选择“**增强功能(预览版)**”选项,然后选择“**创建**”按钮

![名称事件流的图像](./Images/name-eventstream.png)

4. 为“新 Eventstream”命名,选择“增强功能(预览版)”选项,然后选择“创建”按钮****************

>[!注意:] 工作区中新 Eventstream 的创建将在几分钟内完成。 建立之后,你将自动重定向到主编辑器,准备好开始将源集成到 Eventstream 中。
>**注意:** 工作区中新事件流的创建将在几分钟内完成。 建立之后,你将自动重定向到主编辑器,准备好开始将源集成到 Eventstream 中。
## 建立 Eventstream 源

1. 在 Eventstream 画布中,从下拉列表中选择“新建源”,然后选择“示例数据” 。

[ ![“使用示例数据”的图像](./Images/eventstream-select-sample-data.png) ](./Images/eventstream-select-sample-data-large.png#lightbox)

2. 在“添加源”中,为源指定一个名称,然后选择 **自行车(Reflex 兼容)****
1. 选择“添加”按钮。
2. 在“**添加源**”中,为源指定一个名称,然后选择**自行车 (Reflex 兼容)**
3. 选择“添加”按钮。

![选择并命名示例数据 Eventstream](./Images/eventstream-sample-data.png)

1. 选择“添加”按钮后,将映射流并自动重定向到“Eventstream 画布”********
4. 选择“添加”按钮后,将映射流并自动重定向到“Eventstream 画布”********

[ ![查看 Eventstream 画布](./Images/real-time-intelligence-eventstream-sourced.png) ](./Images/real-time-intelligence-eventstream-sourced-large.png#lightbox)

3. 输入下表所示的示例数据的值,然后选择“添加”****

> [!注意:] 创建示例数据源后,你会看到它以“编辑”模式添加到画布上的 Eventstream。 若要实现新添加的示例数据,请选择“发布”****
> **注意:** 创建示例数据源后,你会看到它以“编辑”模式添加到画布上的 Eventstream。 若要实现新添加的示例数据,请选择“发布”****
## 添加转换事件或添加目标活动

Expand All @@ -121,10 +116,9 @@ lab:
- 直接引入:在不进行任何转换的情况下将数据直接引入 KQL 表******
- 在引入前先进行事件处理:在将数据发送到 KQL 表之前,使用事件处理程序转换数据******

> [!WARNING]
> **警告:** 将 KQL 数据库目标添加到 Eventstream 后,无法编辑引入模式****
- 目标名称:输入该 Eventstream 目标的名称,例如“kql-dest”****
- **目标名称:** 输入该 Eventstream 目标的名称,例如“kql-dest”。
- 工作区:KQL 数据库所在的位置****
- KQL 数据库:KQL 数据库的名称****
- 目标表:KQL 表的名称****。 还可以输入名称以创建新表,例如“bike-count”。
Expand All @@ -138,25 +132,32 @@ lab:

1. 在 Eventstream 画布中,选择“转换事件”********

![向转换事件添加“分组依据”。](./Images/eventstream-add-aggregates.png)

A. 选择“分组依据”****

B. 选择“编辑”,以“铅笔”图标表示**********

°C 填写“分组依据”设置部分的属性****
°C 创建“分组依据”转换事件后,需要将其从 Eventstream 连接到“分组依据”************。 无需使用代码即可完成此操作,方法是单击 Eventstream 右侧的点,将其拖动到新的“分组依据”框左侧的点********

[ ![向转换事件添加“分组依据”。](./Images/eventstream-add-aggregates.png) ](./Images/eventstream-add-aggregates-large.png)
![在 Eventstream 和“分组依据”之间添加链接](./Images/group-by-drag-connectors.png)

2. 创建“分组依据”转换事件后,需要将其从 Eventstream 连接到“分组依据”************。 无需使用代码即可完成此操作,方法是单击 Eventstream 右侧的点,将其拖动到新的“分组依据”框左侧的点********
2. 填写**分组依据**设置部分的属性:
- **操作名称:** 输入此转换事件的名称
- **聚合类型:** 总和
- **字段:** No_Bikes
- **名称:** SUM_No_Bikes
- **聚合分组依据:** 街道

3. 依次选择“添加”、“保存”。

[ ![在 Eventstream 和“分组依据”之间添加链接。](./Images/group-by-drag-connectors.png) ](./Images/group-by-drag-connectors-large.png)

3. 同样地,可以将鼠标悬停在 Eventstream 与 kql_dest 之间的箭头上,然后选择“垃圾桶”****************
4. 同样地,可以将鼠标悬停在**事件流*****kql_dest*** 之间的箭头上,然后选择***垃圾桶**。 然后,可以按事件将**分组**连接到 **kql-dest**

[ ![移除两个事件之间的链接](./Images/delete-flow-arrows.png) ](./Images/delete-flow-arrows-large.png)

> [!注意:] 无论何时添加或移除连接器时,都需要重新配置目标对象。
> **注意:** 无论何时添加或移除连接器,都需要重新配置目标对象。
5. 选择 **kql-dest** 下的铅笔,并创建一个名为 **Bike_sum** 的新目标表,该表将接收**分组依据**事件的输出。

## KQL 查询

Expand All @@ -166,7 +167,7 @@ Kusto 查询语言 (KQL) 是处理数据并返回结果的只读请求。 该请
1. 浏览到新创建并经过水化处理的 KQL 数据库:

A. 选择 kql_dest****
A. 选择 **kql-dest**

B. 选择位于“相关项”行中的“打开项”超链接********

Expand All @@ -176,11 +177,11 @@ Kusto 查询语言 (KQL) 是处理数据并返回结果的只读请求。 该请

[ ![移除两个事件之间的链接](./Images/kql-query-sample.png) ](./Images/kql-query-sample-large.png)

3. 示例查询将在“探索数据”窗格中打开,其中已填充表上下文。 第一个查询使用 take 运算符返回示例数量的记录,并且有助于初步了解数据结构和可能的值。 自动填充的示例查询将自动运行。 可在结果窗格中查看查询结果。
3. 示例查询将在“探索数据”窗格中打开,其中已填充表上下文。 第一个查询使用 `take` 运算符返回示例数量的记录,并且有助于初步了解数据结构和可能的值。 自动填充的示例查询将自动运行。 可在结果窗格中查看查询结果。

![KQL 查询结果的图像](./Images/kql-query-results.png)

4. 返回到数据树以选择下一个查询,该查询使用 summarize 运算符计算以 15 分钟为间隔引入的记录数
4. 返回到数据树以选择下一个查询**汇总每小时引入**,其使用 `summarize` 运算符计算在给定时间间隔内引入的记录数

![KQL 查询结果的图像](./Images/kql-query-results-15min-intervals.png)

Expand Down Expand Up @@ -238,4 +239,4 @@ KQL(Kusto 查询语言)数据库中的查询集用途广泛,主要用于
1. 在左侧栏中,选择你的工作区的图标。
2. 在工具栏上的“...”菜单中,选择“工作区设置” 。
3. 在“常规”部分中,选择“删除此工作区”。********

0 comments on commit 453f8b6

Please sign in to comment.