python - 当 DAG 运行时，我们如何处理 python 脚本中的异常？

Question

我是Python和Airflow的新手，我有一些疑问，比如我们如何处理任何异常或者我们如何在Airflow时创建自定义异常。一些场景。

1. 如果我们想要访问/读取任何文件，但文件不可用，在发生 filenotfoundException 的情况下，我们如何处理异常。
2. 在任何数据库(postgres、mysql)中插入数据时，但数据插入不成功，我们如何处理同样的问题。

提前致谢

Answer 1

创建自己的异常子类Exception:

class MyException(Exception):
    pass

请注意，很多时候您不需要这样做，因为所需类型的异常已经存在于标准异常层次结构中。只需使用其中之一即可。请参阅here和 here .

保护 try block 中预期发生某种异常的代码:

try:
    dangerous_code()

except MyException:
    # do something
    ...

如果您愿意，可以手动引发异常:

if condition:
    raise MyException