Airflow与OpsGenie集成问题：告警主题未正确渲染task_instance信息

我之前也碰到过类似的Airflow和OpsGenie集成的主题渲染坑，咱们来拆解问题并解决：

问题根源 #

Airflow的email_alert方法里的default_subject = 'Airflow alert: {{ti}}'是依赖Jinja模板渲染的——常规邮件发送到Gmail时，Airflow的邮件系统会自动解析这个模板变量，把{{ti}}替换成task instance的详细信息；但OpsGenie的集成通道可能没有触发这个渲染流程，导致直接把未解析的模板字符串传了过去，所以主题只显示“Airflow alert:”。

解决方案 #

1. 直接构造主题（最稳妥的方式）

放弃Jinja模板，用Python的字符串拼接/f-string直接生成包含task instance信息的主题，确保内容在发送前就已经是最终状态：

def email_alert(self, exception):
    # 替换原来的default_subject，直接用self（当前task_instance对象）生成详细内容
    default_subject = f'Airflow alert: {self}'
    # 也可以定制更清晰的主题，比如：
    # default_subject = f'Airflow Failure: DAG [{self.dag_id}] Task [{self.task_id}] - {self.execution_date}'
    
    # 后续告警发送逻辑保持不变

self作为task_instance对象，会自动输出包含dag_id、task_id、执行时间等关键信息的字符串，OpsGenie接收时就能直接显示完整主题。

2. 提前渲染Jinja模板

如果你想保留模板语法，可以手动调用Airflow的Jinja渲染器，先把模板变量解析完再发送给OpsGenie：

from airflow.templates import JinjaTemplate

def email_alert(self, exception):
    # 初始化模板并传入ti变量（当前task_instance）
    template = JinjaTemplate('Airflow alert: {{ti}}')
    rendered_subject = template.render(ti=self)
    
    # 用渲染后的subject作为告警主题发送给OpsGenie

这种方式适合需要复用模板逻辑的场景，确保变量被正确解析后再传递。

3. 检查OpsGenie钩子的调用逻辑

如果你的告警是通过OpsgenieHook自定义发送的，要确保在构造告警请求时传递的是已经渲染好的主题，而不是模板字符串：

from airflow.providers.opsgenie.hooks.opsgenie import OpsgenieHook

def custom_opsgenie_alert(context):
    ti = context['task_instance']
    # 先构造好带详细信息的主题
    alert_subject = f'Airflow alert: {ti}'
    
    hook = OpsgenieHook(opsgenie_conn_id='your_opsgenie_conn')
    hook.create_alert(
        message=alert_subject,
        description=f'Task failed with exception: {context["exception"]}',
        tags=['airflow', 'task-failure']
    )

这样就能避免OpsGenie接收到未解析的模板内容。

总结 #

核心问题就是OpsGenie的告警通道不支持Airflow的自动模板渲染，所以要么提前构造好最终主题，要么手动触发渲染流程，就能让告警主题显示完整的task instance信息了。

内容的提问来源于stack exchange，提问作者Gaddy