@@ -3,7 +3,7 @@ title: 使用任务自动化数据加载
3
3
sidebar_label : 任务
4
4
---
5
5
6
- 任务封装了特定的 SQL 语句,旨在按预定间隔 、由特定事件触发或作为更广泛任务序列的一部分执行。在 Databend Cloud 中,任务通常用于定期从流中捕获数据变化,如新增记录,然后将这些数据同步到指定的目标位置。此外,任务还支持 [ Webhook] ( https://en.wikipedia.org/wiki/Webhook ) 和其他消息系统,便于在需要时传递错误消息和通知 。
6
+ 任务封装了特定的 SQL 语句,旨在按预定间隔执行 、由特定事件触发或作为更广泛任务序列的一部分执行。在 Databend Cloud 中,任务通常用于定期从流中捕获数据变化,如新增记录,然后将这些数据同步到指定的目标位置。此外,任务还支持 [ Webhook] ( https://en.wikipedia.org/wiki/Webhook ) 和其他消息系统,便于在需要时发送错误消息和通知 。
7
7
8
8
## 创建任务
9
9
@@ -15,17 +15,17 @@ sidebar_label: 任务
15
15
2 . 指定运行任务的仓库。要创建仓库,请参阅 [ 使用仓库] ( /guides/cloud/using-databend-cloud/warehouses ) 。
16
16
3 . 确定如何触发任务运行。
17
17
18
- - 您可以通过指定分钟或秒的间隔,或使用带有可选时区的 CRON 表达式进行更精确的调度,来安排任务运行 。
18
+ - 您可以通过指定分钟或秒的间隔,或使用带有可选时区的 CRON 表达式进行更精确的调度来安排任务运行 。
19
19
20
20
``` sql title='示例:'
21
- -- 此任务每 2 分钟运行一次
21
+ -- 此任务每2分钟运行一次
22
22
CREATE TASK mytask
23
23
WAREHOUSE = ' default'
24
24
// highlight- next- line
25
25
SCHEDULE = 2 MINUTE
26
26
AS ...
27
27
28
- -- 此任务每天在亚洲/东京时区的午夜(本地时间)运行
28
+ -- 此任务每天在亚洲/东京时区的午夜运行
29
29
CREATE TASK mytask
30
30
WAREHOUSE = ' default'
31
31
// highlight- next- line
47
47
4 . 指定任务执行的条件,允许您根据布尔表达式选择性地控制任务执行。
48
48
49
49
``` sql title='示例:'
50
- -- 此任务每 2 分钟运行一次 ,仅在 'mystream' 包含数据变化时执行 AS 后的 SQL
50
+ -- 此任务每2分钟运行一次 ,仅在 'mystream' 包含数据变化时执行 SQL
51
51
CREATE TASK mytask
52
52
WAREHOUSE = ' default'
53
53
SCHEDULE = 2 MINUTE
@@ -56,10 +56,10 @@ WHEN STREAM_STATUS('mystream') = TRUE
56
56
AS ...
57
57
```
58
58
59
- 5 . 指定任务出错时的处理方式,包括设置连续失败次数以暂停任务,以及指定错误通知的通知集成 。有关设置错误通知的更多信息,请参阅 [ 配置通知集成] ( #configuring-notification-integrations ) 。
59
+ 5 . 指定任务出错时的处理方式,包括设置连续失败次数以暂停任务和指定错误通知的通知集成等选项 。有关设置错误通知的更多信息,请参阅 [ 配置通知集成] ( #configuring-notification-integrations ) 。
60
60
61
61
``` sql title='示例:'
62
- -- 此任务在连续失败 3 次后将暂停
62
+ -- 此任务在连续失败3次后将暂停
63
63
CREATE TASK mytask
64
64
WAREHOUSE = ' default'
65
65
// highlight- next- line
77
77
6 . 指定任务将执行的 SQL 语句。
78
78
79
79
``` sql title='示例:'
80
- -- 此任务每年更新 'employees' 表中的 'age' 列,将其增加 1
80
+ -- 此任务每年更新 'employees' 表中的 'age' 列,将其增加1
81
81
CREATE TASK mytask
82
82
WAREHOUSE = ' default'
83
83
SCHEDULE = USING CRON ' 0 0 1 1 * *' ' UTC'
@@ -87,9 +87,15 @@ UPDATE employees
87
87
SET age = age + 1 ;
88
88
```
89
89
90
+ ## 查看已创建的任务
91
+
92
+ 要查看您的组织创建的所有任务,请登录 Databend Cloud 并转到 ** 数据** > ** 任务** 。您可以查看每个任务的详细信息,包括它们的状态和计划。
93
+
94
+ 要查看任务运行历史,请转到 ** 监控** > ** 任务历史** 。您可以查看每次任务运行的结果、完成时间和其他详细信息。
95
+
90
96
## 配置通知集成
91
97
92
- Databend Cloud 允许您为任务配置错误通知,自动化在任务执行过程中发生错误时发送通知的过程 。它目前支持 Webhook 集成,便于实时将错误事件通信到外部系统或服务。
98
+ Databend Cloud 允许您为任务配置错误通知,当任务执行过程中发生错误时自动发送通知 。它目前支持 Webhook 集成,便于实时将错误事件通信到外部系统或服务。
93
99
94
100
### 任务错误负载
95
101
@@ -129,7 +135,7 @@ Databend Cloud 允许您为任务配置错误通知,自动化在任务执行
129
135
130
136
![ alt text] ( /img/load/webhook-1.png )
131
137
132
- 2 . 在 Databend Cloud 中,创建通知集成,然后使用该通知集成创建任务 :
138
+ 2 . 在 Databend Cloud 中,创建通知集成,然后创建带有通知集成的任务 :
133
139
134
140
``` sql
135
141
-- 创建名为 'my_task' 的任务,每分钟运行一次,错误通知发送到 'my_webhook'。
0 commit comments