event_log表值函數

適用於:檢查標記是的磚的SQL檢查標記是的磚運行時13.1及以後

返回的事件日誌物化視圖,流表,DLT管道

了解更多關於三角洲生活表事件日誌

語法

event_log({(table_name)|pipeline_id})

參數

  • table_name:物化視圖的名稱或流表。這個名字不能包含一個時間規範。如果名稱是不合格的,當前目錄和模式用於限定標識符。

  • pipeline_id:字符串標識符的三角洲住表管道。

返回

  • id字符串事件日誌記錄:一個惟一的標識符。

  • 序列字符串:一個JSON對象,其中包含元數據來識別和秩序的事件。

  • 起源字符串:一個JSON對象包含元數據的起源事件,例如,雲提供商,地區,user_id,或pipeline_id

  • 時間戳時間戳:事件被記錄在UTC時間。

  • 消息字符串:一個人類可讀的描述事件的消息。

  • 水平字符串的日誌級別,例如,信息,警告,錯誤,或指標

  • maturity_level字符串:穩定的事件模式。可能的值是:

    • 穩定的:模式是穩定的,不會改變。

    • :模式是穩定的,不會改變。可能的價值如果記錄被創建之前maturity_level字段添加(版本2022.37)。

    • 不斷發展的:模式不穩定,可能會改變。

    • 棄用:模式是棄用和三角洲生活表運行時可能在任何時間停止生產這個事件。

  • 錯誤字符串:如果一個錯誤發生,細節描述錯誤。

  • 細節字符串:一個JSON對象包含結構化事件的細節。這個主要用於分析事件。

  • event_type字符串:事件類型。

使用

隻有所有者的管道、流表或物化視圖可以查看事件日誌。創建一個視圖和授予用戶訪問視圖允許其他用戶查詢事件日誌。

>創建視圖event_log_raw SELECT * FROM event_log(表(my_mv));>格蘭特選擇視圖event_log_raw“user@m.eheci.com”;

例子

更多的例子,請參考查詢事件日誌

- - -視圖事件一個物化視圖>選擇時間戳,消息,細節event_log((my_mv))在哪裏水平(“信息”,“警告”,“錯誤”)訂單通過時間戳;時間戳,消息,細節- - - - - - - - - - - - - - - - - - - - - - - - - - - - - -2023年- - - - - -08年- - - - - -1201:03:05.000,流“my_mv”開始。,”{flow_progress”:{“狀態”:“開始”}}”- - -創建一個臨時視圖最新的更新/管道>創建取代臨時視圖latest_update作為選擇起源update_id作為idevent_log(“< pipeline-ID >”)在哪裏event_type=“create_update”訂單通過時間戳DESC限製1;- - -查詢血統信息>選擇細節:flow_definitionoutput_dataset作為output_dataset,細節:flow_definitioninput_datasets作為input_datasetevent_log(“< pipeline-ID >”),latest_update在哪裏event_type=“flow_definition”起源update_id=latest_updateid;output_dataset,input_dataset- - - - - - - - - - - - - - - - - - - - - - - - - - - - - -beplay体育app下载地址,sales_orders_raw,sales_orders_cleaned,(“beplay体育app下载地址顧客”,“sales_orders_raw”]sales_order_in_la,(“sales_orders_cleaned”]- - -查詢數據質量期望曆史一個流媒體>expectations_parsed作為(選擇爆炸(from_json(細節:flow_progressdata_quality預期,“數組< struct <名稱:字符串,數據集:字符串,passed_records: int, failed_records: int > >”))row_expectationsevent_log((my_st)),latest_update在哪裏event_type=“flow_progress”起源update_id=latest_updateid)選擇row_expectations數據集作為數據集,row_expectations的名字作為期望,總和(row_expectationspassed_records)作為passing_records,總和(row_expectationsfailed_records)作為failing_recordsexpectations_parsed集團通過row_expectations數據集,row_expectations的名字;數據集,期望,passing_records,failing_records- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -sales_orders_cleaned,valid_order_number,4083年,0