{"id":113867,"date":"2026-10-07T19:49:16","date_gmt":"2026-10-07T11:49:16","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/113867.html"},"modified":"2026-10-07T19:49:16","modified_gmt":"2026-10-07T11:49:16","slug":"sqlmesh-%e5%91%8a%e8%ad%a6%e5%ae%9e%e6%88%98%ef%bc%9a%e5%8f%aa%e7%94%a8-yaml-%e9%85%8d%e7%bd%ae%e5%92%8c-sql-%e6%a8%a1%e5%9e%8b%ef%bc%8c%e6%90%ad%e4%b8%80%e5%a5%97%e6%95%b0%e6%8d%ae%e7%ae%a1%e9%81%93","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/113867.html","title":{"rendered":"SQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66"},"content":{"rendered":"

\u8fd9\u4e00\u7bc7\u4e0d\u5199\u4e00\u884c Python\u3002\u5168\u7a0b\u53ea\u7528\u4e24\u6837\u4e1c\u897f：config.yml \u914d\u7f6e\u6587\u4ef6，\u548c .sql \u6a21\u578b\u6587\u4ef6\u3002<\/p>\n

\u76ee\u6807\u5f88\u5b9e\u5728：SQLMesh \u5b9a\u65f6\u4efb\u52a1\u534a\u591c\u8dd1\u6302\u4e86\u3001\u4e0a\u6e38\u6570\u636e\u51fa\u73b0\u810f\u503c\u4e86，\u8ba9\u544a\u8b66\u81ea\u52a8\u53d1\u5230\u503c\u73ed\u540c\u5b66\u7684\u90ae\u7bb1\u91cc\u3002<\/p>\n

\u6587\u4e2d\u6240\u6709 SQLMesh \u884c\u4e3a（\u4e8b\u4ef6\u540d\u3001YAML \u5b57\u6bb5\u3001\u5ba1\u8ba1\u51fd\u6570\u7b7e\u540d）\u5747\u6765\u81ea\u5b98\u65b9 Notifications guide\u3001Auditing \u6587\u6863，\u4ee5\u53ca\u6e90\u7801 notification_target.py \u9010\u6761\u6838\u5bf9\u3002<\/p>\n

\n

\u4e00\u3001\u5148\u641e\u6e05\u695a：SQLMesh \u80fd\u544a\u4ec0\u4e48\u8b66<\/h3>\n

\u544a\u8b66\u4e0d\u662f\u300c\u8dd1\u5b8c\u53d1\u4e2a\u6d88\u606f\u300d\u8fd9\u4e48\u7b3c\u7edf\u3002SQLMesh \u7684\u901a\u77e5\u662f\u4e8b\u4ef6\u9a71\u52a8\u7684\u2014\u2014\u4f60\u5728 notify_on \u91cc\u58f0\u660e\u8ba2\u9605\u54ea\u4e9b\u4e8b\u4ef6，SQLMesh \u5c31\u53ea\u5728\u90a3\u4e9b\u65f6\u523b\u53d1\u901a\u77e5\u3002<\/p>\n

\u4ece\u6e90\u7801\u7684 NotificationEvent \u679a\u4e3e\u770b，\u5b9e\u9645\u6709 10 \u4e2a\u4e8b\u4ef6（\u5b98\u65b9\u6587\u6863\u9875\u7684\u8868\u683c\u53ea\u5217\u4e86 7 \u4e2a，migration_* \u90a3\u4e09\u4e2a\u6ca1\u5199\u8fdb\u53bb）：<\/p>\n\n\u4e8b\u4ef6notify_on \u503c\u89e6\u53d1\u65f6\u673a\u6d88\u606f\u5185\u5bb9<\/tr>\n\n\n\n\n\n\n\n\n\n\n\n
Plan \u5f00\u59cb<\/td>\napply_start<\/td>\nsqlmesh plan \u5f00\u59cb\u5e94\u7528<\/td>\nPlan \\\\{plan_id}` apply started for environment `{environment}`.`<\/td>\n<\/tr>\n
Plan \u7ed3\u675f<\/td>\napply_end<\/td>\nplan \u5e94\u7528\u6210\u529f<\/td>\nPlan \\\\{plan_id}` apply finished for environment `{environment}`.`<\/td>\n<\/tr>\n
Plan \u5931\u8d25<\/td>\napply_failure<\/td>\nplan \u5e94\u7528\u629b\u5f02\u5e38<\/td>\nPlan \\\\{plan_id}` in environment `{environment}` apply failed.` + \u5f02\u5e38\u6808<\/td>\n<\/tr>\n
Run \u5f00\u59cb<\/td>\nrun_start<\/td>\nsqlmesh run \u5f00\u59cb<\/td>\nSQLMesh run started for environment \\\\{environment}`.`<\/td>\n<\/tr>\n
Run \u7ed3\u675f<\/td>\nrun_end<\/td>\nrun \u6210\u529f\u5b8c\u6210<\/td>\nSQLMesh run finished for environment \\\\{environment}`.`<\/td>\n<\/tr>\n
Run \u5931\u8d25<\/td>\nrun_failure<\/td>\nrun \u629b\u5f02\u5e38<\/td>\nSQLMesh run failed. + \u5f02\u5e38\u6808<\/td>\n<\/tr>\n
\u5ba1\u8ba1\u5931\u8d25<\/td>\naudit_failure<\/td>\n\u6570\u636e\u8d28\u91cf\u6821\u9a8c\u4e0d\u901a\u8fc7<\/td>\nAudit failure. + \u5ba1\u8ba1\u9519\u8bef\u8be6\u60c5<\/td>\n<\/tr>\n
Migration \u5f00\u59cb<\/td>\nmigration_start<\/td>\n\u5185\u90e8\u72b6\u6001\u8868\u8fc1\u79fb\u5f00\u59cb<\/td>\nSQLMesh migration started.<\/td>\n<\/tr>\n
Migration \u7ed3\u675f<\/td>\nmigration_end<\/td>\n\u8fc1\u79fb\u5b8c\u6210<\/td>\nSQLMesh migration finished.<\/td>\n<\/tr>\n
Migration \u5931\u8d25<\/td>\nmigration_failure<\/td>\n\u8fc1\u79fb\u629b\u5f02\u5e38<\/td>\nSQLMesh migration failed. + \u5f02\u5e38\u6808<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

📌 migration_* \u503c\u5f97\u5355\u72ec\u8bf4\u4e00\u53e5\u3002 \u5b83\u662f SQLMesh \u5347\u7ea7\u7248\u672c\u65f6\u5bf9\u5185\u90e8\u72b6\u6001\u8868\u505a\u7ed3\u6784\u8fc1\u79fb\u7684\u4e8b\u4ef6\u3002\u8fc1\u79fb\u5931\u8d25\u610f\u5473\u7740\u5143\u6570\u636e\u53ef\u80fd\u5904\u4e8e\u4e0d\u4e00\u81f4\u72b6\u6001，\u662f\u6bd4\u5355\u6b21 run \u5931\u8d25\u66f4\u4e25\u91cd\u7684\u95ee\u9898\u3002\u5b98\u65b9\u6587\u6863\u9875\u6ca1\u5217\u8fd9\u4e09\u4e2a\u4e8b\u4ef6，\u4f46\u6e90\u7801\u91cc\u6709，\u53ef\u4ee5\u6b63\u5e38\u8ba2\u9605\u3002<\/p>\n

\u5b9e\u8df5\u5efa\u8bae：\u65e5\u5e38\u751f\u4ea7\u53ea\u8ba2\u9605\u52a0\u7c97\u7684 4 \u4e2a\u5931\u8d25\u7c7b\u4e8b\u4ef6\u3002run_start \/ run_end \u5728\u591a\u73af\u5883\u9879\u76ee\u91cc\u4f1a\u4e3a\u6bcf\u4e2a\u73af\u5883\u5404\u53d1\u4e00\u6761，\u5f88\u5bb9\u6613\u628a\u90ae\u7bb1\u5237\u6210\u566a\u97f3，\u7136\u540e\u6240\u6709\u4eba\u5bf9\u544a\u8b66\u514d\u75ab\u2014\u2014\u90a3\u662f\u6bd4\u6ca1\u6709\u544a\u8b66\u66f4\u7cdf\u7684\u72b6\u6001\u3002\u6210\u529f\u4e0e\u5426\u7528\u65e5\u62a5\u6c47\u603b\u5c31\u591f\u4e86\u3002 \"\u5728\u8fd9\u91cc\u63d2\u5165\u56fe\u7247\u63cf\u8ff0\"<\/p>\n

\n

\u4e8c\u3001\u6700\u5c0f\u53ef\u7528：run \u5931\u8d25\u81ea\u52a8\u53d1\u90ae\u4ef6<\/h3>\n

2.1 config.yml<\/h4>\n

SQLMesh \u9879\u76ee\u6839\u76ee\u5f55\u7684 config.yml \u91cc\u52a0\u4e00\u6bb5 notification_targets：<\/p>\n

model_defaults<\/span>:<\/span>
\n dialect<\/span>:<\/span> duckdb
\n start<\/span>:<\/span> 2024-01-01<\/span><\/p>\n

notification_targets<\/span>:<\/span>
\n –<\/span> type<\/span>:<\/span> smtp
\n notify_on<\/span>:<\/span>
\n –<\/span> run_failure
\n host<\/span>:<\/span> smtp.example.com
\n port<\/span>:<\/span> 465<\/span>
\n user<\/span>:<\/span> data–<\/span>alert@example.com
\n password<\/span>:<\/span> "\u4f60\u7684\u90ae\u7bb1\u6388\u6743\u7801"<\/span>
\n sender<\/span>:<\/span> data–<\/span>alert@example.com
\n recipients<\/span>:<\/span>
\n –<\/span> data–<\/span>team@example.com
\n –<\/span> oncall@example.com<\/p>\n

\u5c31\u8fd9\u4e48\u591a\u3002sqlmesh run \u4e00\u65e6\u5931\u8d25，\u4e0a\u9762\u4e24\u4e2a\u6536\u4ef6\u4eba\u5c31\u4f1a\u6536\u5230\u90ae\u4ef6\u3002<\/p>\n

2.2 \u5173\u952e\u5b57\u6bb5\u8bf4\u660e<\/h4>\n\n\u5b57\u6bb5\u8bf4\u660e<\/tr>\n\n\n\n\n\n\n\n\n\n
type<\/td>\n\u90ae\u4ef6\u7528 smtp\u3002\u5185\u7f6e\u8fd8\u652f\u6301 slack_webhook \/ slack_api \/ console \/ generic<\/td>\n<\/tr>\n
notify_on<\/td>\n\u8ba2\u9605\u7684\u4e8b\u4ef6\u5217\u8868，\u503c\u89c1\u4e0a\u8868<\/td>\n<\/tr>\n
host<\/td>\nSMTP \u670d\u52a1\u5668\u5730\u5740<\/td>\n<\/tr>\n
port<\/td>\n\u9ed8\u8ba4 465（\u6e90\u7801\u91cc port: int = 465）<\/td>\n<\/tr>\n
user \/ password<\/td>\n\u767b\u5f55\u51ed\u636e\u3002\u56fd\u5185\u90ae\u7bb1\u8fd9\u91cc\u586b\u6388\u6743\u7801，\u4e0d\u662f\u767b\u5f55\u5bc6\u7801<\/td>\n<\/tr>\n
sender<\/td>\n\u53d1\u4ef6\u4eba\u5730\u5740，\u901a\u5e38\u9700\u8981\u548c user \u4e00\u81f4，\u5426\u5219\u4f1a\u88ab\u670d\u52a1\u5668\u62d2\u7edd<\/td>\n<\/tr>\n
recipients<\/td>\n\u6536\u4ef6\u4eba\u5217\u8868，\u53ef\u591a\u4e2a<\/td>\n<\/tr>\n
subject<\/td>\n\u90ae\u4ef6\u4e3b\u9898，\u9ed8\u8ba4 SQLMesh Notification（\u6e90\u7801\u652f\u6301，\u5b98\u65b9\u6587\u6863\u9875\u6ca1\u63d0）<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

\u26a0\ufe0f \u4e00\u4e2a\u5fc5\u987b\u77e5\u9053\u7684\u9650\u5236：\u6e90\u7801\u91cc\u90ae\u4ef6\u53d1\u9001\u7528\u7684\u662f smtplib.SMTP_SSL，\u4e5f\u5c31\u662f\u53ea\u652f\u6301\u9690\u5f0f SSL，\u4e0d\u652f\u6301 STARTTLS\u3002\u5982\u679c\u4f60\u7684\u4f01\u4e1a\u90ae\u7bb1（\u81ea\u5efa Exchange\u3001\u90e8\u5206\u5185\u7f51 MTA）\u53ea\u5f00\u4e86 25 \u6216 587 \u7aef\u53e3 + STARTTLS，\u5185\u7f6e smtp \u76ee\u6807\u7528\u4e0d\u4e86\u3002\u8fd9\u79cd\u60c5\u51b5\u7684\u89e3\u6cd5\u89c1\u672c\u7cfb\u5217\u7b2c\u4e8c\u7bc7\u3002<\/p>\n

2.3 \u51ed\u636e\u4e0d\u8981\u786c\u7f16\u7801\u8fdb\u914d\u7f6e\u6587\u4ef6<\/h4>\n

config.yml \u662f\u8981\u63d0\u4ea4\u5230 Git \u7684，\u5bc6\u7801\u5199\u8fdb\u53bb\u7b49\u4e8e\u516c\u5f00\u3002SQLMesh \u7684 YAML \u652f\u6301 env_var() \u6a21\u677f\u51fd\u6570：<\/p>\n

notification_targets<\/span>:<\/span>
\n –<\/span> type<\/span>:<\/span> smtp
\n notify_on<\/span>:<\/span>
\n –<\/span> run_failure
\n –<\/span> apply_failure
\n –<\/span> audit_failure
\n host<\/span>:<\/span> "{{ env_var('SMTP_HOST') }}"<\/span>
\n port<\/span>:<\/span> 465<\/span>
\n user<\/span>:<\/span> "{{ env_var('SMTP_USER') }}"<\/span>
\n password<\/span>:<\/span> "{{ env_var('SMTP_PASSWORD') }}"<\/span>
\n sender<\/span>:<\/span> data–<\/span>alert@example.com
\n recipients<\/span>:<\/span>
\n –<\/span> data–<\/span>team@example.com
\n subject<\/span>:<\/span> "[\u6570\u636e\u4ed3\u5e93] SQLMesh \u7ba1\u9053\u544a\u8b66"<\/span><\/p>\n

\u8bbe\u7f6e\u73af\u5883\u53d8\u91cf：<\/p>\n

# Linux \/ macOS<\/span>
\nexport<\/span> SMTP_HOST<\/span>=<\/span>"smtp.example.com"<\/span>
\nexport<\/span> SMTP_USER<\/span>=<\/span>"data-alert@example.com"<\/span>
\nexport<\/span> SMTP_PASSWORD<\/span>=<\/span>"\u4f60\u7684\u6388\u6743\u7801"<\/span><\/p>\n

# Windows PowerShell<\/span>
\n$env<\/span>:SMTP_HOST = "smtp.example.com"<\/span>
\n$env<\/span>:SMTP_USER = "data-alert@example.com"<\/span>
\n$env<\/span>:SMTP_PASSWORD = "\u4f60\u7684\u6388\u6743\u7801"<\/span><\/p>\n

\u5b9a\u65f6\u4efb\u52a1\u91cc\u8bb0\u5f97\u628a\u8fd9\u4e9b\u53d8\u91cf\u5199\u8fdb\u8c03\u5ea6\u5668（Airflow \u7684 Connection\u3001crontab \u7684\u73af\u5883\u6bb5\u3001systemd \u7684 Environment=），\u5426\u5219 cron \u73af\u5883\u8bfb\u4e0d\u5230\u4f60 shell \u91cc export \u7684\u53d8\u91cf\u2014\u2014\u8fd9\u662f\u300c\u672c\u5730\u80fd\u53d1\u3001\u4e0a\u4e86\u8c03\u5ea6\u5c31\u53d1\u4e0d\u51fa\u53bb\u300d\u6700\u5e38\u89c1\u7684\u539f\u56e0\u3002<\/p>\n

\n

\u4e09\u3001\u5931\u8d25\u957f\u4ec0\u4e48\u6837：\u90ae\u4ef6\u6b63\u6587\u9884\u89c8<\/h3>\n

\u90ae\u4ef6\u6b63\u6587\u7531\u4e24\u90e8\u5206\u62fc\u6210：msg（\u56fa\u5b9a\u6587\u6848）+ \u5f02\u5e38\u6808\u3002\u4ee5 run \u5931\u8d25\u4e3a\u4f8b，\u4f60\u4f1a\u6536\u5230：<\/p>\n

Subject: [\u6570\u636e\u4ed3\u5e93] SQLMesh \u7ba1\u9053\u544a\u8b66
\nTo: data-team@example.com
\nFrom: data-alert@example.com<\/p>\n

SQLMesh run failed.
\nTraceback (most recent call last):
\n File "…\/sqlmesh\/core\/scheduler.py", line 214, in run
\n …
\nsqlglot.errors.ExecuteError: Binder Error: Referenced column "order_dt" not found
\nin FROM clause! Candidate bindings: "sushi.orders.start_ts", "sushi.orders.id"
\nLINE 12: WHERE order_dt >= '2024-03-01'<\/p>\n

\u5ba1\u8ba1\u5931\u8d25\u7684\u6b63\u6587\u5219\u662f Audit failure. \u52a0\u4e0a\u5ba1\u8ba1\u9519\u8bef\u7684\u5b57\u7b26\u4e32\u5f62\u5f0f，\u5176\u4e2d\u5305\u542b\u5ba1\u8ba1\u540d\u3001\u6a21\u578b\u540d\u3001\u8fdd\u89c4\u884c\u6570\u548c\u5b9e\u9645\u6267\u884c\u7684\u5ba1\u8ba1 SQL\u3002<\/p>\n

\n

\u56db\u3001SQL \u6a21\u578b + Audits：\u628a\u300c\u6570\u636e\u8d28\u91cf\u544a\u8b66\u300d\u4e5f\u7ba1\u8d77\u6765<\/h3>\n

\u524d\u9762\u662f\u300c\u7ba1\u9053\u8dd1\u6302\u4e86\u300d\u7684\u544a\u8b66\u3002\u4f46\u66f4\u5e38\u89c1\u3001\u4e5f\u66f4\u5371\u9669\u7684\u60c5\u51b5\u662f：\u7ba1\u9053\u8dd1\u6210\u529f\u4e86，\u6570\u636e\u5374\u662f\u9519\u7684\u2014\u2014\u4e0a\u6e38\u6f0f\u63a8\u4e86\u4e00\u6279\u3001\u91d1\u989d\u51fa\u73b0\u8d1f\u6570\u3001\u4e3b\u952e\u91cd\u590d\u4e86\u3002\u4efb\u52a1\u5168\u7eff，\u62a5\u8868\u5168\u9519，\u6ca1\u4eba\u77e5\u9053\u3002<\/p>\n

SQLMesh \u7684 audits \u5c31\u662f\u5e72\u8fd9\u4e2a\u7684：\u5b83\u662f\u4e00\u6bb5 SQL \u67e5\u8be2，\u8fd4\u56de\u4efb\u4f55\u884c\u5c31\u4ee3\u8868\u5931\u8d25\u3002\u6bcf\u6b21 run\/plan \u65f6\u81ea\u52a8\u6267\u884c\u3002\u8fd9\u4e00\u8282\u5168\u90e8\u662f\u7eaf SQL\u3002<\/p>\n

4.1 \u9879\u76ee\u7ed3\u6784<\/h4>\n

my_project\/
\n\u251c\u2500\u2500 config.yml
\n\u251c\u2500\u2500 models\/
\n\u2502 \u251c\u2500\u2500 orders.sql
\n\u2502 \u251c\u2500\u2500 items.sql
\n\u2502 \u2514\u2500\u2500 customers.sql
\n\u2514\u2500\u2500 audits\/
\n \u2514\u2500\u2500 generic.sql \u2190 \u81ea\u5b9a\u4e49\u5ba1\u8ba1\u653e\u8fd9\u91cc<\/p>\n

4.2 \u7528\u5185\u7f6e\u5ba1\u8ba1（\u6700\u7701\u4e8b，\u8986\u76d6 80% \u573a\u666f）<\/h4>\n

SQLMesh \u5185\u7f6e\u4e86\u4e00\u5927\u6279\u901a\u7528\u5ba1\u8ba1，\u4e0d\u9700\u8981\u4f60\u5199\u4efb\u4f55 SQL，\u53ea\u8981\u5728\u6a21\u578b\u7684 MODEL \u8bed\u53e5\u91cc\u58f0\u660e\u5373\u53ef\u3002<\/p>\n

models\/orders.sql：<\/p>\n

MODEL (<\/span>
\n name sushi.<\/span>orders,<\/span>
\n kind INCREMENTAL_BY_TIME_RANGE (<\/span>
\n time_column ds
\n )<\/span>,<\/span>
\n owner data<\/span>–<\/span>eng@example.com<\/span>,<\/span>
\n audits (<\/span>
\n not_null(<\/span>columns<\/span> :=<\/span> (<\/span>id,<\/span> customer_id,<\/span> start_ts,<\/span> end_ts)<\/span>)<\/span>,<\/span>
\n unique_values(<\/span>columns<\/span> :=<\/span> (<\/span>id)<\/span>)<\/span>,<\/span>
\n number_of_rows(<\/span>threshold :=<\/span> 100<\/span>)<\/span>,<\/span>
\n accepted_range(<\/span>column<\/span> :=<\/span> item_id,<\/span> min_v :=<\/span> 1<\/span>,<\/span> max_v :=<\/span> 100000<\/span>)<\/span>,<\/span>
\n accepted_values(<\/span>column<\/span> :=<\/span> status<\/span>,<\/span> is_in :=<\/span> (<\/span>'placed'<\/span>,<\/span> 'paid'<\/span>,<\/span> 'shipped'<\/span>,<\/span> 'done'<\/span>,<\/span> 'cancelled'<\/span>)<\/span>)<\/span>,<\/span>
\n forall(<\/span>criteria :=<\/span> (<\/span>
\n end_ts >=<\/span> start_ts,<\/span>
\n quantity ><\/span> 0<\/span>
\n )<\/span>)<\/span>
\n )<\/span>
\n)<\/span>;<\/span><\/p>\n

SELECT<\/span>
\n id,<\/span>
\n customer_id,<\/span>
\n item_id,<\/span>
\n quantity,<\/span>
\n status<\/span>,<\/span>
\n start_ts,<\/span>
\n end_ts,<\/span>
\n CAST(<\/span>start_ts AS<\/span> DATE<\/span>)<\/span> AS<\/span> ds
\nFROM<\/span> sushi.<\/span>raw_orders
\nWHERE<\/span> ds BETWEEN<\/span> @start_ds<\/span> AND<\/span> @end_ds<\/span><\/p>\n

\u8fd9\u51e0\u884c audits (…) \u58f0\u660e\u7684\u542b\u4e49：<\/p>\n\n\u5ba1\u8ba1\u4f5c\u7528\u53c2\u6570<\/tr>\n\n\n\n\n\n\n\n
not_null<\/td>\n\u6307\u5b9a\u5217\u4e0d\u5141\u8bb8\u6709 NULL<\/td>\ncolumns := (…)<\/td>\n<\/tr>\n
unique_values<\/td>\n\u6307\u5b9a\u5217\u503c\u5fc5\u987b\u552f\u4e00（\u65e0\u91cd\u590d）<\/td>\ncolumns := (…)<\/td>\n<\/tr>\n
number_of_rows<\/td>\n\u884c\u6570\u5fc5\u987b\u8d85\u8fc7\u9608\u503c\u2014\u2014\u4e0a\u6e38\u6f0f\u63a8\u6570\u636e\u7684\u7ecf\u5178\u54e8\u5175<\/td>\nthreshold := N<\/td>\n<\/tr>\n
accepted_range<\/td>\n\u6570\u503c\u5fc5\u987b\u843d\u5728\u533a\u95f4\u5185<\/td>\ncolumn\u3001min_v\u3001max_v\u3001\u53ef\u9009 inclusive := false<\/td>\n<\/tr>\n
accepted_values<\/td>\n\u679a\u4e3e\u503c\u767d\u540d\u5355<\/td>\ncolumn\u3001is_in := (…)<\/td>\n<\/tr>\n
forall<\/td>\n\u4e07\u80fd\u6b3e：\u4efb\u610f\u5e03\u5c14\u8868\u8fbe\u5f0f\u5fc5\u987b\u5bf9\u6240\u6709\u884c\u4e3a TRUE<\/td>\ncriteria := (expr1, expr2, …)<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

models\/items.sql \u518d\u6765\u4e00\u7ec4，\u6f14\u793a\u5b57\u7b26\u4e32\u548c\u7edf\u8ba1\u7c7b\u5ba1\u8ba1：<\/p>\n

MODEL (<\/span>
\n name sushi.<\/span>items,<\/span>
\n kind FULL<\/span>,<\/span>
\n owner data<\/span>–<\/span>eng@example.com<\/span>,<\/span>
\n audits (<\/span>
\n not_empty_string(<\/span>column<\/span> :=<\/span> name)<\/span>,<\/span>
\n string_length_between(<\/span>column<\/span> :=<\/span> name,<\/span> min_v :=<\/span> 2<\/span>,<\/span> max_v :=<\/span> 50<\/span>)<\/span>,<\/span>
\n accepted_range(<\/span>column<\/span> :=<\/span> price,<\/span> min_v :=<\/span> 0.01<\/span>,<\/span> max_v :=<\/span> 1000<\/span>,<\/span> inclusive :=<\/span> false<\/span>)<\/span>,<\/span>
\n mean_in_range(<\/span>column<\/span> :=<\/span> price,<\/span> min_v :=<\/span> 5<\/span>,<\/span> max_v :=<\/span> 50<\/span>)<\/span>,<\/span>
\n z_score(<\/span>column<\/span> :=<\/span> price,<\/span> threshold :=<\/span> 4<\/span>)<\/span>,<\/span>
\n unique_combination_of_columns(<\/span>columns<\/span> :=<\/span> (<\/span>id,<\/span> ds)<\/span>)<\/span>
\n )<\/span>
\n)<\/span>;<\/span><\/p>\n

SELECT<\/span> id,<\/span> name,<\/span> price,<\/span> CAST(<\/span>ds AS<\/span> DATE<\/span>)<\/span> AS<\/span> ds
\nFROM<\/span> sushi.<\/span>seed<\/p>\n

📌 z_score(column := price, threshold := 4) \u662f\u4e2a\u5f88\u597d\u7528\u7684\u5f02\u5e38\u503c\u54e8\u5175：\u4efb\u4f55\u4e00\u884c\u7684 z \u5206\u6570\u7edd\u5bf9\u503c\u8d85\u8fc7 4 \u5c31\u544a\u8b66\u3002\u4ef7\u683c\u91cc\u6df7\u8fdb\u4e00\u4e2a 999999 \u4e4b\u7c7b\u7684\u810f\u503c，\u5b83\u4f1a\u7acb\u523b\u6293\u4f4f\u3002<\/p>\n

📌 \u7edf\u8ba1\u7c7b\u5ba1\u8ba1（mean_in_range \/ stddev_in_range \/ z_score）\u7684\u9608\u503c\u51e0\u4e4e\u5fc5\u7136\u9700\u8981\u53cd\u590d\u8bd5\u9519\u8c03\u6574，\u5b98\u65b9\u6587\u6863\u4e5f\u660e\u786e\u8fd9\u4e48\u63d0\u9192\u3002\u522b\u6307\u671b\u4e00\u6b21\u914d\u5bf9\u3002<\/p>\n

4.3 \u5185\u7f6e\u5ba1\u8ba1\u5168\u6e05\u5355（\u6309\u7528\u9014\u5206\u7ec4）<\/h4>\n

\u901a\u7528\u65ad\u8a00<\/p>\n

    \n
  • forall(criteria := (…)) \u2014 \u4efb\u610f\u5e03\u5c14\u8868\u8fbe\u5f0f<\/li>\n<\/ul>\n

    \u884c\u6570\u4e0e\u7a7a\u503c<\/p>\n

      \n
    • number_of_rows(threshold := N)<\/li>\n
    • not_null(columns := (…))<\/li>\n
    • at_least_one(column := c) \u2014 \u8be5\u5217\u81f3\u5c11\u6709\u4e00\u4e2a\u975e NULL \u503c<\/li>\n
    • not_null_proportion(column := c, threshold := 0.8) \u2014 NULL \u5360\u6bd4\u4e0d\u8d85\u8fc7\u9608\u503c<\/li>\n<\/ul>\n

      \u5177\u4f53\u53d6\u503c<\/p>\n

        \n
      • not_constant(column := c) \u2014 \u81f3\u5c11\u6709\u4e24\u4e2a\u4e0d\u540c\u7684\u975e NULL \u503c（\u80fd\u53d1\u73b0\u300c\u6574\u5217\u53d8\u6210\u540c\u4e00\u4e2a\u503c\u300d）<\/li>\n
      • unique_values(columns := (…))<\/li>\n
      • unique_combination_of_columns(columns := (…))<\/li>\n
      • accepted_values(column := c, is_in := (…))<\/li>\n
      • not_accepted_values(column := c, is_in := (…))<\/li>\n<\/ul>\n

        \u6570\u503c\u5206\u5e03<\/p>\n

          \n
        • sequential_values(column := c, interval := 1) \u2014 \u503c\u5fc5\u987b\u9010\u4e2a\u9012\u589e\u6307\u5b9a\u6b65\u957f（\u67e5\u65ad\u53f7\u5f88\u597d\u7528）<\/li>\n
        • accepted_range(column := c, min_v := , max_v := , inclusive := )<\/li>\n
        • mutually_exclusive_ranges(lower_bound_column := , upper_bound_column := ) \u2014 \u533a\u95f4\u4e0d\u5f97\u91cd\u53e0<\/li>\n<\/ul>\n

          \u5b57\u7b26\u4e32<\/p>\n

            \n
          • not_empty_string(column := c)<\/li>\n
          • string_length_equal(column := c, v := N)<\/li>\n
          • string_length_between(column := c, min_v := , max_v := , inclusive := )<\/li>\n
          • valid_uuid(column := c)<\/li>\n
          • valid_email(column := c)<\/li>\n
          • valid_url(column := c)<\/li>\n
          • valid_http_method(column := c)<\/li>\n
          • match_regex_pattern_list(column := c, patterns := (…))<\/li>\n
          • not_match_regex_pattern_list(column := c, patterns := (…))<\/li>\n
          • match_like_pattern_list(column := c, patterns := (…))<\/li>\n
          • not_match_like_pattern_list(column := c, patterns := (…))<\/li>\n<\/ul>\n

            \u7edf\u8ba1<\/p>\n

              \n
            • mean_in_range(column := c, min_v := , max_v := )<\/li>\n
            • stddev_in_range(column := c, min_v := , max_v := )<\/li>\n
            • z_score(column := c, threshold := N)<\/li>\n
            • kl_divergence(column := c, target_column := ref, threshold := 0.1) \u2014 \u4e24\u5217\u5206\u5e03\u5dee\u5f02（PSI）<\/li>\n
            • chi_square(column := c, target_column := ref, critical_value := 6.635)<\/li>\n<\/ul>\n

              \u26a0\ufe0f \u4e24\u4e2a\u5b98\u65b9\u660e\u786e\u63d0\u9192\u7684 NULL \u9677\u9631：<\/p>\n

                \n
              • accepted_values：NULL \u884c\u5728\u591a\u6570\u6570\u636e\u5e93\u91cc\u4f1a\u901a\u8fc7\u3002\u8981\u6321 NULL \u5f97\u53e6\u914d not_null\u3002<\/li>\n
              • not_accepted_values：\u4e0d\u652f\u6301\u62d2\u7edd NULL\u3002\u540c\u4e0a\u3002<\/li>\n<\/ul>\n

                4.4 \u81ea\u5b9a\u4e49\u5ba1\u8ba1：\u5199\u4f60\u81ea\u5df1\u7684 SQL \u89c4\u5219<\/h4>\n

                \u5185\u7f6e\u7684\u4e0d\u591f\u7528\u65f6，\u5728 audits\/ \u76ee\u5f55\u5efa .sql \u6587\u4ef6\u81ea\u5df1\u5199\u3002\u89c4\u5219\u5f88\u7b80\u5355：\u67e5\u8be2\u8fd4\u56de\u884c = \u5ba1\u8ba1\u5931\u8d25\u3002<\/p>\n

                audits\/generic.sql：<\/p>\n

                — \u89c4\u5219 1：\u8ba2\u5355\u91d1\u989d\u4e0d\u80fd\u4e3a\u8d1f<\/span>
                \nAUDIT (<\/span>
                \n name assert_amount_not_negative
                \n)<\/span>;<\/span>
                \nSELECT<\/span> *<\/span>
                \nFROM<\/span> @this_model<\/span>
                \nWHERE<\/span> amount <<\/span> 0<\/span>;<\/span><\/p>\n

                — \u89c4\u5219 2：\u5e26\u53c2\u6570\u7684\u901a\u7528\u5ba1\u8ba1\u2014\u2014\u67d0\u5217\u4e0d\u5f97\u8d85\u8fc7\u9608\u503c<\/span>
                \nAUDIT (<\/span>
                \n name does_not_exceed_threshold,<\/span>
                \n defaults (<\/span>
                \n threshold =<\/span> 10<\/span>
                \n )<\/span>
                \n)<\/span>;<\/span>
                \nSELECT<\/span> *<\/span>
                \nFROM<\/span> @this_model<\/span>
                \nWHERE<\/span> @column<\/span> >=<\/span> @threshold<\/span>;<\/span><\/p>\n

                — \u89c4\u5219 3：\u589e\u91cf\u6a21\u578b\u4e13\u7528\u2014\u2014\u5f53\u5929\u7684\u6570\u636e\u5fc5\u987b\u8986\u76d6\u5230\u6700\u65b0\u4e00\u5c0f\u65f6<\/span>
                \n— （\u80fd\u53d1\u73b0\u300c\u4efb\u52a1\u6210\u529f\u4f46\u53ea\u8dd1\u4e86\u4e00\u534a\u300d\u7684\u60c5\u51b5）<\/span>
                \nAUDIT (<\/span>
                \n name assert_partition_is_fresh
                \n)<\/span>;<\/span>
                \nSELECT<\/span> *<\/span>
                \nFROM<\/span> @this_model<\/span>
                \nWHERE<\/span> ds =<\/span> @end_ds<\/span>
                \n AND<\/span> EXTRACT(<\/span>HOUR<\/span> FROM<\/span> MAX<\/span>(<\/span>event_time)<\/span>)<\/span> <<\/span> 20<\/span>;<\/span><\/p>\n

                — \u89c4\u5219 4：\u8de8\u6a21\u578b\u4e00\u81f4\u6027\u2014\u2014\u8ba2\u5355\u91cc\u7684 customer_id \u5fc5\u987b\u5728\u5ba2\u6237\u8868\u91cc\u5b58\u5728<\/span>
                \nAUDIT (<\/span>
                \n name assert_customer_exists
                \n)<\/span>;<\/span>
                \nSELECT<\/span> o.<\/span>customer_id
                \nFROM<\/span> @this_model<\/span> AS<\/span> o
                \nLEFT<\/span> JOIN<\/span> sushi.<\/span>customers AS<\/span> c
                \n ON<\/span> o.<\/span>customer_id =<\/span> c.<\/span>id
                \nWHERE<\/span> o.<\/span>ds BETWEEN<\/span> @start_ds<\/span> AND<\/span> @end_ds<\/span>
                \n AND<\/span> c.<\/span>id IS<\/span> NULL<\/span>;<\/span><\/p>\n

                @this_model \u662f\u4e2a\u7279\u6b8a\u5b8f，\u6307\u5411\u6b63\u5728\u88ab\u5ba1\u8ba1\u7684\u6a21\u578b；\u5bf9\u589e\u91cf\u6a21\u578b\u5b83\u8fd8\u4fdd\u8bc1\u53ea\u67e5\u76f8\u5173\u7684\u65f6\u95f4\u533a\u95f4\u3002@column\u3001@threshold \u662f\u53c2\u6570，\u5728\u6a21\u578b\u58f0\u660e\u65f6\u4f20\u5165\u3002@start_ds \/ @end_ds \u662f\u5f53\u524d\u5904\u7406\u533a\u95f4\u3002<\/p>\n

                \u5728\u6a21\u578b\u91cc\u5f15\u7528：<\/p>\n

                MODEL (<\/span>
                \n name sushi.<\/span>orders,<\/span>
                \n kind INCREMENTAL_BY_TIME_RANGE (<\/span>time_column ds)<\/span>,<\/span>
                \n owner data<\/span>–<\/span>eng@example.com<\/span>,<\/span>
                \n audits (<\/span>
                \n assert_amount_not_negative,<\/span>
                \n does_not_exceed_threshold(<\/span>column<\/span> :=<\/span> quantity,<\/span> threshold :=<\/span> 500<\/span>)<\/span>,<\/span>
                \n does_not_exceed_threshold(<\/span>column<\/span> :=<\/span> amount,<\/span> threshold :=<\/span> 100000<\/span>)<\/span>,<\/span>
                \n assert_partition_is_fresh,<\/span>
                \n assert_customer_exists
                \n )<\/span>
                \n)<\/span>;<\/span><\/p>\n

                \u6ce8\u610f\u540c\u4e00\u4e2a\u901a\u7528\u5ba1\u8ba1\u53ef\u4ee5\u7528\u4e0d\u540c\u53c2\u6570\u91cd\u590d\u5e94\u7528（\u4e0a\u9762 does_not_exceed_threshold \u7528\u4e86\u4e24\u6b21）\u3002<\/p>\n

                💡 \u5982\u679c\u5ba1\u8ba1\u7684\u53c2\u6570\u540d\u649e\u4e0a SQL \u5173\u952e\u5b57（\u6bd4\u5982\u53eb values），\u8c03\u7528\u65f6\u8981\u52a0\u5f15\u53f7：my_audit(column := a, "values" := (1,2,3))\u3002<\/p>\n

                4.5 \u5185\u8054\u5ba1\u8ba1：\u89c4\u5219\u548c\u6a21\u578b\u5199\u5728\u4e00\u8d77<\/h4>\n

                \u4e0d\u60f3\u5355\u72ec\u5efa audits\/ \u6587\u4ef6\u7684\u8bdd，\u5ba1\u8ba1\u53ef\u4ee5\u76f4\u63a5\u5199\u5728\u6a21\u578b\u6587\u4ef6\u672b\u5c3e：<\/p>\n

                MODEL (<\/span>
                \n name sushi.<\/span>customers,<\/span>
                \n kind FULL<\/span>,<\/span>
                \n audits (<\/span>
                \n not_null(<\/span>columns<\/span> :=<\/span> (<\/span>id)<\/span>)<\/span>,<\/span>
                \n assert_email_or_phone
                \n )<\/span>
                \n)<\/span>;<\/span><\/p>\n

                SELECT<\/span> id,<\/span> name,<\/span> email,<\/span> phone FROM<\/span> sushi.<\/span>raw_customers;<\/span><\/p>\n

                AUDIT (<\/span>
                \n name assert_email_or_phone
                \n)<\/span>;<\/span>
                \nSELECT<\/span> *<\/span> FROM<\/span> @this_model<\/span>
                \nWHERE<\/span> email IS<\/span> NULL<\/span> AND<\/span> phone IS<\/span> NULL<\/span>;<\/span><\/p>\n

                4.6 \u5168\u5c40\u5ba1\u8ba1：\u6240\u6709\u6a21\u578b\u7edf\u4e00\u515c\u5e95<\/h4>\n

                \u6709\u4e9b\u89c4\u5219\u5e94\u8be5\u5bf9\u6bcf\u4e2a\u6a21\u578b\u90fd\u751f\u6548（\u6bd4\u5982\u300c\u4e0d\u5141\u8bb8\u7a7a\u8868\u300d）\u3002\u5199\u5728 config.yml \u7684 model_defaults \u91cc，\u4e0d\u7528\u6bcf\u4e2a\u6a21\u578b\u91cd\u590d\u58f0\u660e：<\/p>\n

                model_defaults<\/span>:<\/span>
                \n dialect<\/span>:<\/span> duckdb
                \n start<\/span>:<\/span> 2024-01-01<\/span>
                \n audits<\/span>:<\/span>
                \n –<\/span> number_of_rows(threshold :<\/span>= 0)
                \n –<\/span> assert_amount_not_negative<\/p>\n

                \u8fd9\u662f YAML \u914d\u7f6e，\u4e0d\u662f Python\u2014\u2014model_defaults.audits \u76f4\u63a5\u652f\u6301\u5e26\u53c2\u6570\u7684\u5199\u6cd5\u3002<\/p>\n

                \n

                \u4e94\u3001blocking vs non-blocking：\u544a\u8b66\u8981\u4e0d\u8981\u62e6\u4f4f\u7ba1\u9053<\/h3>\n

                \u8fd9\u662f\u5ba1\u8ba1\u914d\u7f6e\u91cc\u6700\u91cd\u8981\u7684\u4e00\u4e2a\u51b3\u5b9a\u3002<\/p>\n

                \u9ed8\u8ba4\u60c5\u51b5\u4e0b，\u6240\u6709\u5ba1\u8ba1\u90fd\u662f blocking（\u963b\u585e）\u7684：\u5ba1\u8ba1\u5931\u8d25\u4f1a\u4e2d\u6b62 plan \u6216 run，\u9632\u6b62\u810f\u6570\u636e\u5f80\u4e0b\u6e38\u4f20\u64ad\u3002<\/p>\n

                \u4f46 plan \u548c run \u7684\u540e\u679c\u5dee\u522b\u5f88\u5927，\u5fc5\u987b\u5206\u6e05：<\/p>\n\nsqlmesh plansqlmesh run<\/tr>\n\n\n\n\n
                \u4f55\u65f6\u5ba1\u8ba1<\/td>\n\u63d0\u5347\u5230\u751f\u4ea7\u4e4b\u524d<\/td>\n\u76f4\u63a5\u5bf9\u751f\u4ea7\u73af\u5883\u5ba1\u8ba1<\/td>\n<\/tr>\n
                \u5ba1\u8ba1\u5931\u8d25\u540e\u679c<\/td>\nplan \u505c\u6b62，\u751f\u4ea7\u8868\u5b8c\u5168\u6ca1\u88ab\u78b0\u8fc7，\u810f\u6570\u636e\u7559\u5728\u9694\u79bb\u8868\u91cc<\/td>\nrun \u505c\u6b62，\u4f46\u810f\u6570\u636e\u5df2\u7ecf\u5728\u751f\u4ea7\u8868\u91cc\u4e86<\/td>\n<\/tr>\n
                \u4fee\u590d\u65b9\u5f0f<\/td>\n\u6539\u903b\u8f91\u540e\u91cd\u65b0 plan<\/td>\n\u5fc5\u987b\u4fee\u751f\u4ea7\u8868：\u4fee\u4e0a\u6e38 \u2192 \u8dd1 restatement plan<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

                \u6240\u4ee5：\u5728 CI \u91cc\u7528 plan \u9636\u6bb5\u5c31\u62e6\u4f4f\u95ee\u9898，\u6210\u672c\u8fdc\u4f4e\u4e8e\u5728 run \u9636\u6bb5\u53d1\u73b0\u3002<\/p>\n

                5.1 \u4ec0\u4e48\u65f6\u5019\u8be5\u6539\u6210 non-blocking<\/h4>\n

                \u6709\u4e9b\u5ba1\u8ba1\u662f\u300c\u503c\u5f97\u5173\u6ce8\u4f46\u4e0d\u8be5\u505c\u7ba1\u9053\u300d\u7684\u2014\u2014\u6bd4\u5982\u7edf\u8ba1\u7c7b\u9608\u503c（mean_in_range\u3001z_score）\u672c\u8eab\u5c31\u9700\u8981\u957f\u671f\u8c03\u53c2，\u8bef\u62a5\u7387\u9ad8\u3002\u8ba9\u5b83\u963b\u585e\u7ba1\u9053\u4f1a\u9020\u6210\u5927\u91cf\u65e0\u8c13\u7684\u4e2d\u65ad\u3002<\/p>\n

                \u4e24\u79cd\u6539\u6cd5：<\/p>\n

                \u65b9\u6cd5\u4e00：\u5728\u8c03\u7528\u5904\u52a0 blocking := false<\/p>\n

                MODEL (<\/span>
                \n name sushi.<\/span>items,<\/span>
                \n audits (<\/span>
                \n not_null(<\/span>columns<\/span> :=<\/span> (<\/span>id)<\/span>)<\/span>,<\/span> — \u963b\u585e：\u4e3b\u952e\u5fc5\u987b\u6709\u503c<\/span>
                \n accepted_range(<\/span>column<\/span> :=<\/span> price,<\/span> min_v :=<\/span> 0.01<\/span>,<\/span> max_v :=<\/span> 1000<\/span>)<\/span>,<\/span> — \u963b\u585e：\u786c\u89c4\u5219<\/span>
                \n mean_in_range(<\/span>column<\/span> :=<\/span> price,<\/span> min_v :=<\/span> 5<\/span>,<\/span> max_v :=<\/span> 50<\/span>,<\/span> blocking :=<\/span> false<\/span>)<\/span>,<\/span> — \u53ea\u544a\u8b66<\/span>
                \n z_score(<\/span>column<\/span> :=<\/span> price,<\/span> threshold :=<\/span> 4<\/span>,<\/span> blocking :=<\/span> false<\/span>)<\/span> — \u53ea\u544a\u8b66<\/span>
                \n )<\/span>
                \n)<\/span>;<\/span><\/p>\n

                \u65b9\u6cd5\u4e8c：\u76f4\u63a5\u7528\u5185\u7f6e\u7684 _non_blocking \u53d8\u4f53<\/p>\n

                \u6bcf\u4e2a\u5185\u7f6e\u5ba1\u8ba1\u90fd\u6709\u4e00\u4e2a\u540c\u540d + _non_blocking \u540e\u7f00\u7684\u7248\u672c：<\/p>\n

                audits (<\/span>
                \n mean_in_range_non_blocking(<\/span>column<\/span> :=<\/span> price,<\/span> min_v :=<\/span> 5<\/span>,<\/span> max_v :=<\/span> 50<\/span>)<\/span>,<\/span>
                \n z_score_non_blocking(<\/span>column<\/span> :=<\/span> price,<\/span> threshold :=<\/span> 4<\/span>)<\/span>
                \n)<\/span><\/p>\n

                \u65b9\u6cd5\u4e09：\u5728\u5ba1\u8ba1\u5b9a\u4e49\u91cc\u58f0\u660e<\/p>\n

                AUDIT (<\/span>
                \n name assert_item_price_is_not_null,<\/span>
                \n blocking false<\/span>
                \n)<\/span>;<\/span>
                \nSELECT<\/span> *<\/span> FROM<\/span> sushi.<\/span>items
                \nWHERE<\/span> ds BETWEEN<\/span> @start_ds<\/span> AND<\/span> @end_ds<\/span>
                \n AND<\/span> price IS<\/span> NULL<\/span>;<\/span><\/p>\n

                \u26a0\ufe0f \u5173\u952e：non-blocking \u5ba1\u8ba1\u5931\u8d25\u65f6\u4ecd\u7136\u4f1a\u89e6\u53d1 audit_failure \u901a\u77e5\u4e8b\u4ef6\u3002\u8fd9\u6b63\u662f\u6211\u4eec\u60f3\u8981\u7684\u2014\u2014\u300c\u4e0d\u505c\u7ba1\u9053，\u4f46\u8981\u8ba9\u4eba\u77e5\u9053\u300d\u3002<\/p>\n

                5.2 \u4e34\u65f6\u8df3\u8fc7\u67d0\u4e2a\u5ba1\u8ba1<\/h4>\n

                \u8c03\u8bd5\u671f\u95f4\u60f3\u5b8c\u5168\u5173\u6389\u4e00\u4e2a\u5ba1\u8ba1，\u7528 skip：<\/p>\n

                AUDIT (<\/span>
                \n name assert_item_price_is_not_null,<\/span>
                \n skip true<\/span>
                \n)<\/span>;<\/span>
                \nSELECT<\/span> *<\/span> FROM<\/span> sushi.<\/span>items WHERE<\/span> price IS<\/span> NULL<\/span>;<\/span><\/p>\n

                \n

                \u516d\u3001\u5ba1\u8ba1\u5931\u8d25\u544a\u8b66\u7684 5 \u4e2a\u524d\u63d0\u6761\u4ef6（\u6700\u5bb9\u6613\u300c\u914d\u4e86\u6ca1\u53cd\u5e94\u300d\u7684\u5730\u65b9）<\/h3>\n

                \u8fd9\u662f\u672c\u6587\u6700\u5b9e\u7528\u7684\u4e00\u8282\u3002\u5b98\u65b9\u6587\u6863\u660e\u786e\u5199\u4e86：\u5ba1\u8ba1\u5931\u8d25\u901a\u77e5\u8981\u6309\u6a21\u578b\u53d1\u7ed9\u7279\u5b9a\u8d1f\u8d23\u4eba，\u5fc5\u987b\u540c\u65f6\u6ee1\u8db3 5 \u4e2a\u6761\u4ef6：<\/p>\n

              • \u6a21\u578b\u7684 owner \u5b57\u6bb5\u5df2\u586b\u5199<\/li>\n
              • \u8be5\u6a21\u578b\u6267\u884c\u4e86\u4e00\u4e2a\u6216\u591a\u4e2a\u5ba1\u8ba1<\/li>\n
              • \u8be5 owner \u914d\u7f6e\u4e86\u7528\u6237\u7ea7\u901a\u77e5\u76ee\u6807（\u4e0d\u662f\u5168\u5c40\u7684）<\/li>\n
              • \u8be5 owner \u7684\u901a\u77e5\u76ee\u6807 notify_on \u91cc\u5305\u542b\u5ba1\u8ba1\u5931\u8d25\u4e8b\u4ef6<\/li>\n
              • \u5ba1\u8ba1\u5728 prod \u73af\u5883\u5931\u8d25<\/li>\n

                \u5c11\u4efb\u4f55\u4e00\u4e2a，\u4f60\u5c31\u6536\u4e0d\u5230\u901a\u77e5\u3002\u9010\u6761\u5bf9\u5e94\u5230\u914d\u7f6e：<\/p>\n

                \u6761\u4ef6 1 + 2：\u6a21\u578b\u91cc\u8981\u6709 owner \u548c audits<\/p>\n

                MODEL (<\/span>
                \n name sushi.<\/span>orders,<\/span>
                \n kind INCREMENTAL_BY_TIME_RANGE (<\/span>time_column ds)<\/span>,<\/span>
                \n owner zhangsan@example.com<\/span>,<\/span> — \u2190 \u6761\u4ef6 1<\/span>
                \n audits (<\/span> — \u2190 \u6761\u4ef6 2<\/span>
                \n not_null(<\/span>columns<\/span> :=<\/span> (<\/span>id)<\/span>)<\/span>,<\/span>
                \n assert_amount_not_negative
                \n )<\/span>
                \n)<\/span>;<\/span><\/p>\n

                SELECT<\/span> .<\/span>.<\/span>.<\/span> FROM<\/span> sushi.<\/span>raw_orders WHERE<\/span> ds BETWEEN<\/span> @start_ds<\/span> AND<\/span> @end_ds<\/span><\/p>\n

                \u6761\u4ef6 3 + 4：config.yml \u91cc\u8981\u6709\u5bf9\u5e94\u7528\u6237\u540d\u7684\u7528\u6237\u7ea7\u901a\u77e5\u76ee\u6807<\/p>\n

                users<\/span>:<\/span>
                \n –<\/span> username<\/span>:<\/span> zhangsan
                \n notification_targets<\/span>:<\/span>
                \n –<\/span> type<\/span>:<\/span> smtp
                \n notify_on<\/span>:<\/span>
                \n –<\/span> audit_failure # \u2190 \u6761\u4ef6 4<\/span>
                \n host<\/span>:<\/span> "{{ env_var('SMTP_HOST') }}"<\/span>
                \n port<\/span>:<\/span> 465<\/span>
                \n user<\/span>:<\/span> "{{ env_var('SMTP_USER') }}"<\/span>
                \n password<\/span>:<\/span> "{{ env_var('SMTP_PASSWORD') }}"<\/span>
                \n sender<\/span>:<\/span> data–<\/span>alert@example.com
                \n recipients<\/span>:<\/span>
                \n –<\/span> zhangsan@example.com<\/p>\n

                🔥 \u6761\u4ef6 3 \u662f\u6700\u5e38\u8e29\u7684\u5751：\u8fd9\u91cc users[].username \u7684\u503c\u5fc5\u987b\u548c\u6a21\u578b owner \u5b57\u6bb5\u7684\u503c\u5b8c\u5168\u4e00\u81f4（zhangsan@example.com），SQLMesh \u5c31\u662f\u9760\u8fd9\u4e2a\u5b57\u7b26\u4e32\u628a\u300c\u54ea\u4e2a\u6a21\u578b\u51fa\u95ee\u9898\u300d\u6620\u5c04\u5230\u300c\u8be5\u901a\u77e5\u8c01\u300d\u7684\u3002\u5199\u6210 zhangsan \u800c owner \u5199 zhangsan@example.com，\u901a\u77e5\u5c31\u9759\u9ed8\u5931\u6548\u3002<\/p>\n

                \u6761\u4ef6 5：\u53ea\u5728 prod \u89e6\u53d1\u3002\u5f00\u53d1\u73af\u5883（\u865a\u62df\u73af\u5883）\u91cc\u5ba1\u8ba1\u5931\u8d25\u4e0d\u4f1a\u53d1\u8fd9\u7c7b\u5b9a\u5411\u901a\u77e5\u3002<\/p>\n

                6.1 \u5b8c\u6574\u793a\u4f8b：\u6309\u8d1f\u8d23\u4eba\u5206\u53d1 + \u56e2\u961f\u515c\u5e95<\/h4>\n

                model_defaults<\/span>:<\/span>
                \n dialect<\/span>:<\/span> duckdb
                \n start<\/span>:<\/span> 2024-01-01<\/span>
                \n audits<\/span>:<\/span>
                \n –<\/span> number_of_rows(threshold :<\/span>= 0)<\/p>\n

                # \u2500\u2500 \u5168\u5c40\u76ee\u6807：\u7ba1\u9053\u7ea7\u6545\u969c\u53d1\u7ed9\u6574\u4e2a\u56e2\u961f \u2500\u2500<\/span>
                \nnotification_targets<\/span>:<\/span>
                \n –<\/span> type<\/span>:<\/span> smtp
                \n notify_on<\/span>:<\/span>
                \n –<\/span> run_failure
                \n –<\/span> apply_failure
                \n –<\/span> migration_failure
                \n host<\/span>:<\/span> "{{ env_var('SMTP_HOST') }}"<\/span>
                \n port<\/span>:<\/span> 465<\/span>
                \n user<\/span>:<\/span> "{{ env_var('SMTP_USER') }}"<\/span>
                \n password<\/span>:<\/span> "{{ env_var('SMTP_PASSWORD') }}"<\/span>
                \n sender<\/span>:<\/span> data–<\/span>alert@example.com
                \n recipients<\/span>:<\/span>
                \n –<\/span> data–<\/span>team@example.com
                \n –<\/span> oncall@example.com
                \n subject<\/span>:<\/span> "[\u6570\u636e\u4ed3\u5e93] SQLMesh \u7ba1\u9053\u6545\u969c"<\/span><\/p>\n

                # \u2500\u2500 \u7528\u6237\u7ea7\u76ee\u6807：\u6570\u636e\u8d28\u91cf\u544a\u8b66\u53d1\u7ed9\u5bf9\u5e94 owner \u2500\u2500<\/span>
                \nusers<\/span>:<\/span>
                \n –<\/span> username<\/span>:<\/span> zhangsan@example.com
                \n notification_targets<\/span>:<\/span>
                \n –<\/span> type<\/span>:<\/span> smtp
                \n notify_on<\/span>:<\/span>
                \n –<\/span> audit_failure
                \n host<\/span>:<\/span> "{{ env_var('SMTP_HOST') }}"<\/span>
                \n port<\/span>:<\/span> 465<\/span>
                \n user<\/span>:<\/span> "{{ env_var('SMTP_USER') }}"<\/span>
                \n password<\/span>:<\/span> "{{ env_var('SMTP_PASSWORD') }}"<\/span>
                \n sender<\/span>:<\/span> data–<\/span>alert@example.com
                \n recipients<\/span>:<\/span>
                \n –<\/span> zhangsan@example.com
                \n subject<\/span>:<\/span> "[\u6570\u636e\u8d28\u91cf] \u4f60\u8d1f\u8d23\u7684\u6a21\u578b\u5ba1\u8ba1\u5931\u8d25"<\/span><\/p>\n

                –<\/span> username<\/span>:<\/span> lisi@example.com
                \n notification_targets<\/span>:<\/span>
                \n –<\/span> type<\/span>:<\/span> smtp
                \n notify_on<\/span>:<\/span>
                \n –<\/span> audit_failure
                \n host<\/span>:<\/span> "{{ env_var('SMTP_HOST') }}"<\/span>
                \n port<\/span>:<\/span> 465<\/span>
                \n user<\/span>:<\/span> "{{ env_var('SMTP_USER') }}"<\/span>
                \n password<\/span>:<\/span> "{{ env_var('SMTP_PASSWORD') }}"<\/span>
                \n sender<\/span>:<\/span> data–<\/span>alert@example.com
                \n recipients<\/span>:<\/span>
                \n –<\/span> lisi@example.com
                \n subject<\/span>:<\/span> "[\u6570\u636e\u8d28\u91cf] \u4f60\u8d1f\u8d23\u7684\u6a21\u578b\u5ba1\u8ba1\u5931\u8d25"<\/span><\/p>\n

                \u8fd9\u6837\u7684\u5206\u5de5\u5f88\u6e05\u6670：\u7ba1\u9053\u6302\u4e86\u627e\u503c\u73ed，\u6570\u636e\u810f\u4e86\u627e owner\u3002<\/p>\n

                \n

                \u4e03\u3001\u5f00\u53d1\u671f\u9632\u5237\u5c4f：username \u5f00\u5173<\/h3>\n

                \u5f00\u53d1\u65f6\u4f1a\u53cd\u590d sqlmesh plan，\u6bcf\u6b21\u90fd\u5f80\u56e2\u961f\u90ae\u7bb1\u53d1\u901a\u77e5\u4f1a\u8fc5\u901f\u62db\u4eba\u70e6\u3002SQLMesh \u63d0\u4f9b\u4e86\u4e00\u4e2a\u9876\u5c42 username \u5f00\u5173：<\/p>\n

                # \u53ea\u6709 zhangsan \u7684\u901a\u77e5\u76ee\u6807\u4f1a\u751f\u6548，\u5176\u4ed6\u5168\u90e8\u9759\u97f3<\/span>
                \nusername<\/span>:<\/span> zhangsan<\/p>\n

                users<\/span>:<\/span>
                \n –<\/span> username<\/span>:<\/span> zhangsan
                \n notification_targets<\/span>:<\/span>
                \n –<\/span> type<\/span>:<\/span> smtp
                \n notify_on<\/span>:<\/span>
                \n –<\/span> apply_start
                \n –<\/span> apply_end
                \n –<\/span> run_start
                \n –<\/span> run_end
                \n host<\/span>:<\/span> "{{ env_var('SMTP_HOST') }}"<\/span>
                \n port<\/span>:<\/span> 465<\/span>
                \n user<\/span>:<\/span> "{{ env_var('SMTP_USER') }}"<\/span>
                \n password<\/span>:<\/span> "{{ env_var('SMTP_PASSWORD') }}"<\/span>
                \n sender<\/span>:<\/span> data–<\/span>alert@example.com
                \n recipients<\/span>:<\/span>
                \n –<\/span> zhangsan@example.com
                \n subject<\/span>:<\/span> "[\u5f00\u53d1\u73af\u5883] SQLMesh \u901a\u77e5（\u4ec5\u672c\u4eba）"<\/span><\/p>\n

                \u26a0\ufe0f \u4e0a\u9762\u8fd9\u6bb5\u662f\u5b8c\u6574\u53ef\u590d\u5236\u7684\u914d\u7f6e\u3002\u6ce8\u610f YAML \u91cc\u5355\u72ec\u4e00\u884c\u7684 … \u662f\u6587\u6863\u7ed3\u675f\u7b26，\u4e0d\u662f\u7701\u7565\u53f7\u2014\u2014\u5199\u5728\u7f29\u8fdb\u7ed3\u6784\u91cc\u4f1a\u76f4\u63a5\u5bfc\u81f4\u89e3\u6790\u62a5\u9519（could not find expected ':'）\u3002\u6587\u6863\u91cc\u5e38\u89c1\u7684 … \u53ea\u662f\u4e3a\u4e86\u793a\u610f\u300c\u6b64\u5904\u7701\u7565\u300d，\u5b9e\u9645\u914d\u7f6e\u5fc5\u987b\u8865\u5168\u5b57\u6bb5\u3002<\/p>\n

                \u6e90\u7801\u903b\u8f91（NotificationTargetManager.notify）\u662f：\u5982\u679c\u8bbe\u7f6e\u4e86 username，\u5c31\u53ea\u8c03\u7528\u8be5\u7528\u6237\u7684\u901a\u77e5\u76ee\u6807，\u5168\u5c40\u76ee\u6807\u5168\u90e8\u8df3\u8fc7\u3002<\/p>\n

                \u66f4\u597d\u7684\u505a\u6cd5：\u628a\u5b83\u653e\u5728\u673a\u5668\u7ea7\u914d\u7f6e ~\/.sqlmesh\/config.yml \u91cc，\u800c\u4e0d\u662f\u9879\u76ee\u914d\u7f6e\u91cc\u3002\u8fd9\u6837：<\/p>\n

                  \n
                • \u4f60\u7684\u5f00\u53d1\u673a \u2192 \u53ea\u901a\u77e5\u4f60\u81ea\u5df1<\/li>\n
                • \u751f\u4ea7\u8c03\u5ea6\u673a \u2192 \u6ca1\u6709\u8fd9\u4e2a\u914d\u7f6e \u2192 \u5168\u5458\u6b63\u5e38\u901a\u77e5<\/li>\n
                • \u9879\u76ee\u914d\u7f6e\u6587\u4ef6\u4fdd\u6301\u5e72\u51c0，\u4e0d\u4f1a\u6709\u4eba\u4e0d\u5c0f\u5fc3\u628a\u81ea\u5df1\u7684 username \u63d0\u4ea4\u4e0a\u53bb\u5bfc\u81f4\u751f\u4ea7\u544a\u8b66\u5168\u54d1<\/li>\n<\/ul>\n

                  # ~\/.sqlmesh\/config.yml （\u53ea\u5728\u4f60\u81ea\u5df1\u7684\u5f00\u53d1\u673a\u4e0a）<\/span>
                  \nusername<\/span>:<\/span> zhangsan<\/p>\n

                  \u26a0\ufe0f \u8fd9\u6761\u503c\u5f97\u53cd\u590d\u5f3a\u8c03：\u5982\u679c\u8bef\u628a username: \u67d0\u4eba \u63d0\u4ea4\u5230\u4e86\u9879\u76ee\u7684 config.yml，\u751f\u4ea7\u73af\u5883\u7684\u6240\u6709\u544a\u8b66\u90fd\u53ea\u4f1a\u53d1\u7ed9\u90a3\u4e00\u4e2a\u4eba，\u56e2\u961f\u91cc\u5176\u4ed6\u4eba\u548c\u503c\u73ed\u7ec4\u5b8c\u5168\u6536\u4e0d\u5230\u2014\u2014\u800c\u4e14\u4e0d\u4f1a\u6709\u4efb\u4f55\u62a5\u9519\u3002\u6392\u67e5\u544a\u8b66\u7f3a\u5931\u65f6，\u8fd9\u662f\u7b2c\u4e00\u4e2a\u8981\u68c0\u67e5\u7684\u5730\u65b9\u3002<\/p>\n

                  \n

                  \u516b\u3001\u9a8c\u8bc1：\u600e\u4e48\u786e\u8ba4\u544a\u8b66\u771f\u7684\u80fd\u53d1\u51fa\u6765<\/h3>\n

                  \u6211\u6ca1\u6709\u53ef\u8fd0\u884c\u7684 SQLMesh \u73af\u5883\u548c\u771f\u5b9e\u90ae\u7bb1\u51ed\u636e，\u672c\u6587\u914d\u7f6e\u672a\u505a\u7aef\u5230\u7aef\u5b9e\u6d4b\u3002 \u4e0b\u9762\u662f\u4ece\u4f4e\u6210\u672c\u5230\u9ad8\u6210\u672c\u7684\u9a8c\u8bc1\u987a\u5e8f：<\/p>\n

                  \u7b2c 1 \u6b65：\u7528 console \u76ee\u6807\u786e\u8ba4\u4e8b\u4ef6\u88ab\u89e6\u53d1<\/h4>\n

                  \u6e90\u7801\u91cc\u6709\u4e2a console \u7c7b\u578b（\u6ce8\u91ca\u8bf4\u662f\u7559\u7ed9\u6d4b\u8bd5\u7528\u7684），\u5b83\u628a\u901a\u77e5\u6253\u5230\u63a7\u5236\u53f0，\u4e0d\u9700\u8981\u4efb\u4f55\u5916\u90e8\u4f9d\u8d56：<\/p>\n

                  notification_targets<\/span>:<\/span>
                  \n –<\/span> type<\/span>:<\/span> console
                  \n notify_on<\/span>:<\/span>
                  \n –<\/span> run_start
                  \n –<\/span> run_end
                  \n –<\/span> run_failure
                  \n –<\/span> apply_start
                  \n –<\/span> apply_end
                  \n –<\/span> apply_failure
                  \n –<\/span> audit_failure<\/p>\n

                  \u8fd9\u4e00\u6b65\u80fd\u628a\u300cSQLMesh \u6ca1\u89e6\u53d1\u4e8b\u4ef6\u300d\u548c\u300c\u90ae\u4ef6\u53d1\u9001\u73af\u8282\u6709\u95ee\u9898\u300d\u5f7b\u5e95\u5206\u5f00\u3002\u5efa\u8bae\u5148\u505a\u8fd9\u6b65\u3002<\/p>\n

                  \u7b2c 2 \u6b65：\u5355\u72ec\u6d4b\u5ba1\u8ba1\u89c4\u5219<\/h4>\n

                  \u5ba1\u8ba1\u53ef\u4ee5\u8131\u79bb run \u5355\u72ec\u6267\u884c：<\/p>\n

                  sqlmesh -p<\/span> .\/my_project audit –start<\/span> 2024<\/span>-03-01 –end<\/span> 2024<\/span>-03-02<\/p>\n

                  \u5931\u8d25\u65f6\u7684\u8f93\u51fa\u957f\u8fd9\u6837，\u4fe1\u606f\u91cf\u5f88\u8db3：<\/p>\n

                  Found 1 audit(s).
                  \nassert_item_price_is_not_null FAIL.<\/p>\n

                  Finished with 1 audit error(s).<\/p>\n

                  Failure in audit assert_item_price_is_not_null for model sushi.items (audits\/items.sql).
                  \nGot 3 results, expected 0.
                  \nSELECT * FROM sqlmesh.sushi__items__1836721418_83893210 WHERE ds BETWEEN '2024-03-01' AND '2024-03-02' AND price IS NULL<\/p>\n

                  Got 3 results, expected 0 \u76f4\u63a5\u544a\u8bc9\u4f60\u6709 3 \u884c\u810f\u6570\u636e，\u8fd8\u4f1a\u6253\u5370\u5b9e\u9645\u6267\u884c\u7684 SQL（\u542b\u7269\u7406\u8868\u540d），\u53ef\u4ee5\u590d\u5236\u51fa\u6765\u5355\u72ec\u67e5\u8fd9 3 \u884c\u3002<\/p>\n

                  \u7b2c 3 \u6b65：\u4eba\u4e3a\u5236\u9020\u4e00\u6b21\u5931\u8d25，\u9a8c\u8bc1\u90ae\u4ef6\u901a\u8def<\/h4>\n
                    \n
                  • \u6d4b run_failure：\u4e34\u65f6\u628a\u67d0\u4e2a\u6a21\u578b\u7684 SQL \u6539\u6210\u5fc5\u7136\u62a5\u9519\u7684（\u6bd4\u5982\u5f15\u7528\u4e00\u4e2a\u4e0d\u5b58\u5728\u7684\u5217），\u8dd1 sqlmesh run，\u770b\u90ae\u4ef6\u5230\u6ca1\u5230\u3002\u6d4b\u5b8c\u8bb0\u5f97\u6539\u56de\u6765\u3002<\/li>\n
                  • \u6d4b audit_failure：\u4e34\u65f6\u628a\u67d0\u4e2a\u5ba1\u8ba1\u7684\u9608\u503c\u8c03\u5230\u5fc5\u7136\u4e0d\u901a\u8fc7（\u6bd4\u5982 number_of_rows(threshold := 999999999)），\u8dd1\u4e00\u6b21\u3002<\/li>\n<\/ul>\n

                    \u7b2c 4 \u6b65：\u5728\u8c03\u5ea6\u73af\u5883\u91cc\u518d\u9a8c\u4e00\u6b21<\/h4>\n

                    \u7b2c 3 \u6b65\u5728\u672c\u5730\u901a\u8fc7 \u2260 \u751f\u4ea7\u901a\u8fc7\u3002\u6700\u5e38\u89c1\u7684\u4e24\u4e2a\u65ad\u70b9：<\/p>\n

                  • \u73af\u5883\u53d8\u91cf\u6ca1\u4f20\u8fdb\u8c03\u5ea6\u5668\u2014\u2014cron \/ Airflow worker \u7684\u73af\u5883\u548c\u4f60\u7684 shell \u4e0d\u4e00\u6837\u3002<\/li>\n
                  • \u7f51\u7edc\u7b56\u7565\u2014\u2014\u751f\u4ea7\u673a\u5668\u53ef\u80fd\u4e0d\u5141\u8bb8\u76f4\u8fde\u5916\u90e8 SMTP \u7684 465 \u7aef\u53e3\u3002<\/li>\n
                    \n

                    \u4e5d\u3001\u5c0f\u7ed3<\/h3>\n

                    \u53ea\u7528 YAML + SQL，\u80fd\u505a\u5230\u7684\u4e8b：<\/p>\n

                      \n
                    • \u7ba1\u9053\u6545\u969c\u544a\u8b66：notification_targets + type: smtp + notify_on: [run_failure, apply_failure, migration_failure]<\/li>\n
                    • \u6570\u636e\u8d28\u91cf\u544a\u8b66：\u6a21\u578b\u7684 audits (…) \u58f0\u660e + \u5185\u7f6e\u5ba1\u8ba1 + audits\/*.sql \u81ea\u5b9a\u4e49\u89c4\u5219<\/li>\n
                    • \u544a\u8b66\u5206\u7ea7：blocking \u62e6\u7ba1\u9053，blocking := false \/ _non_blocking \u53ea\u544a\u8b66<\/li>\n
                    • \u8d23\u4efb\u5230\u4eba：\u6a21\u578b owner + users[].notification_targets + notify_on: [audit_failure]<\/li>\n
                    • \u5168\u5c40\u515c\u5e95：model_defaults.audits \u7edf\u4e00\u89c4\u5219，\u9876\u5c42 notification_targets \u901a\u77e5\u56e2\u961f<\/li>\n
                    • \u5f00\u53d1\u671f\u9759\u97f3：~\/.sqlmesh\/config.yml \u91cc\u7684 username<\/li>\n<\/ul>\n

                      \u505a\u4e0d\u5230\u7684\u4e8b：\u5185\u7f6e IM \u901a\u9053\u53ea\u6709 Slack，\u56fd\u5185\u56e2\u961f\u7528\u4e0d\u4e0a；\u5185\u7f6e SMTP \u53ea\u652f\u6301 SSL 465\u3002\u8fd9\u4e24\u6761\u90fd\u9700\u8981\u81ea\u5b9a\u4e49\u901a\u77e5\u76ee\u6807\u2014\u2014\u89c1\u672c\u7cfb\u5217\u7b2c\u4e8c\u7bc7\u300a\u81ea\u5b9a\u4e49\u901a\u77e5\u6e20\u9053：\u628a SQLMesh \u544a\u8b66\u63a5\u5230\u9489\u9489\u548c\u4efb\u610f Webhook\u300b\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"

                      \u8fd9\u4e00\u7bc7\u4e0d\u5199\u4e00\u884c Python\u3002\u5168\u7a0b\u53ea\u7528\u4e24\u6837\u4e1c\u897f：config.yml \u914d\u7f6e\u6587\u4ef6，\u548c .sql \u6a21\u578b\u6587\u4ef6\u3002 \u76ee\u6807\u5f88\u5b9e\u5728：SQLMesh \u5b9a\u65f6\u4efb\u52a1\u534a\u591c\u8dd1\u6302\u4e86\u3001\u4e0a\u6e38\u6570\u636e\u51fa\u73b0\u810f\u503c\u4e86，\u8ba9\u544a\u8b66\u81ea\u52a8\u53d1\u5230\u503c\u73ed\u540c\u5b66\u7684\u90ae\u7bb1\u91cc\u3002 \u6587\u4e2d\u6240\u6709 SQLMesh \u884c\u4e3a（\u4e8b\u4ef6\u540d\u3001YAML \u5b57\u6bb5\u3001\u5ba1\u8ba1\u51fd\u6570\u7b7e\u540d）\u5747\u6765\u81ea\u5b98\u65b9 Notifications guide\u3001Auditing \u6587\u6863，\u4ee5\u53ca\u6e90\u7801 notificat<\/p>\n","protected":false},"author":2,"featured_media":113866,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[12953,11653,12954,323],"topic":[],"class_list":["post-113867","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-sqlmesh","tag-11653","tag-12954","tag-323"],"yoast_head":"\nSQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/113867.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"SQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"\u8fd9\u4e00\u7bc7\u4e0d\u5199\u4e00\u884c Python\u3002\u5168\u7a0b\u53ea\u7528\u4e24\u6837\u4e1c\u897f：config.yml \u914d\u7f6e\u6587\u4ef6，\u548c .sql \u6a21\u578b\u6587\u4ef6\u3002 \u76ee\u6807\u5f88\u5b9e\u5728：SQLMesh \u5b9a\u65f6\u4efb\u52a1\u534a\u591c\u8dd1\u6302\u4e86\u3001\u4e0a\u6e38\u6570\u636e\u51fa\u73b0\u810f\u503c\u4e86，\u8ba9\u544a\u8b66\u81ea\u52a8\u53d1\u5230\u503c\u73ed\u540c\u5b66\u7684\u90ae\u7bb1\u91cc\u3002 \u6587\u4e2d\u6240\u6709 SQLMesh \u884c\u4e3a（\u4e8b\u4ef6\u540d\u3001YAML \u5b57\u6bb5\u3001\u5ba1\u8ba1\u51fd\u6570\u7b7e\u540d）\u5747\u6765\u81ea\u5b98\u65b9 Notifications guide\u3001Auditing \u6587\u6863，\u4ee5\u53ca\u6e90\u7801 notificat\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/113867.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-10-07T11:49:16+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/10\/20261007114915-6ac631bb8b274.png\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"10 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/113867.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/113867.html\",\"name\":\"SQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-10-07T11:49:16+00:00\",\"dateModified\":\"2026-10-07T11:49:16+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/113867.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/113867.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/113867.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"SQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"SQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/113867.html","og_locale":"zh_CN","og_type":"article","og_title":"SQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"\u8fd9\u4e00\u7bc7\u4e0d\u5199\u4e00\u884c Python\u3002\u5168\u7a0b\u53ea\u7528\u4e24\u6837\u4e1c\u897f：config.yml \u914d\u7f6e\u6587\u4ef6，\u548c .sql \u6a21\u578b\u6587\u4ef6\u3002 \u76ee\u6807\u5f88\u5b9e\u5728：SQLMesh \u5b9a\u65f6\u4efb\u52a1\u534a\u591c\u8dd1\u6302\u4e86\u3001\u4e0a\u6e38\u6570\u636e\u51fa\u73b0\u810f\u503c\u4e86，\u8ba9\u544a\u8b66\u81ea\u52a8\u53d1\u5230\u503c\u73ed\u540c\u5b66\u7684\u90ae\u7bb1\u91cc\u3002 \u6587\u4e2d\u6240\u6709 SQLMesh \u884c\u4e3a（\u4e8b\u4ef6\u540d\u3001YAML \u5b57\u6bb5\u3001\u5ba1\u8ba1\u51fd\u6570\u7b7e\u540d）\u5747\u6765\u81ea\u5b98\u65b9 Notifications guide\u3001Auditing \u6587\u6863，\u4ee5\u53ca\u6e90\u7801 notificat","og_url":"https:\/\/www.wsisp.com\/helps\/113867.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-10-07T11:49:16+00:00","og_image":[{"url":"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/10\/20261007114915-6ac631bb8b274.png"}],"author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"10 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/113867.html","url":"https:\/\/www.wsisp.com\/helps\/113867.html","name":"SQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-10-07T11:49:16+00:00","dateModified":"2026-10-07T11:49:16+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/113867.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/113867.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/113867.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"SQLMesh \u544a\u8b66\u5b9e\u6218\uff1a\u53ea\u7528 YAML \u914d\u7f6e\u548c SQL \u6a21\u578b\uff0c\u642d\u4e00\u5957\u6570\u636e\u7ba1\u9053\u544a\u8b66"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/113867","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=113867"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/113867\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media\/113866"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=113867"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=113867"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=113867"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=113867"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}