我是新来的,你能帮我一下吗?我想知道如何通过电报机器人设置一个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
]
1条答案
按热度按时间gcuhipw91#
挂钩尚未与您正在使用的“软件定义资产”一起实现。您可以在此处为该功能投赞成票:https://github.com/dagster-io/dagster/issues/8577
你得先想个变通的办法。