python 如何设置failure_hook以从电报机器人发送消息

3htmauhk  于 2022-11-21  发布在  Python
关注(0)|答案(1)|浏览(88)

我是新来的,你能帮我一下吗?我想知道如何通过电报机器人设置一个ETL过程错误通知
我的代码:

from dagster import (
    load_assets_from_package_module,
    asset,
    repository,
    define_asset_job,
    ScheduleDefinition
)

import pyodbc
import pandas as pd

#import package_module.etl as assets
@asset
def get_categories():
    conn = pyodbc.connect()
    df = pd.read_sql_query(
    """SQL QUERY"""
, conn)
    return df.to_csv('path/to/file',index=False)

daily_job = define_asset_job(name="daily_refresh", selection="*")
daily_schedule = ScheduleDefinition(
    job=daily_job,
    cron_schedule="@daily",
)

@repository
def etl():
    return [
        daily_job,
        daily_schedule,
        #load_assets_from_package_module(assets),
        get_categories
    ]
gcuhipw9

gcuhipw91#

挂钩尚未与您正在使用的“软件定义资产”一起实现。您可以在此处为该功能投赞成票:https://github.com/dagster-io/dagster/issues/8577
你得先想个变通的办法。

相关问题