airflow.providers.atlassian.jira.sensors.jira¶

类¶

`JiraSensor`	监控 Jira 事务的任何变更。
`JiraTicketSensor`	根据函数监控 Jira 事务的给定变更。

模块内容¶

class airflow.providers.atlassian.jira.sensors.jira.JiraSensor(*, method_name, jira_conn_id='jira_default', method_params=None, result_processor=None, **kwargs)[源代码]¶

基类: airflow.sensors.base.BaseSensorOperator

监控 Jira 事务的任何变更。

参数:

jira_conn_id (str) – 引用预定义的 Jira 连接
method_name (str) – 要执行的 atlassian-python-api JIRA sdk 方法名称
method_params (dict | None) – 方法 method_name 的参数
result_processor (Callable | None) – 返回布尔值并作为 sensor 响应的函数

jira_conn_id = 'jira_default'[源代码]¶

result_processor = None[源代码]¶

method_name[源代码]¶

method_params = None[源代码]¶

poke(context)[源代码]¶

派生此类时重写。

class airflow.providers.atlassian.jira.sensors.jira.JiraTicketSensor(*, jira_conn_id='jira_default', ticket_id=None, field=None, expected_value=None, field_checker_func=None, **kwargs)[源代码]¶

基类: JiraSensor

根据函数监控 Jira 事务的给定变更。

参数:

jira_conn_id (str) – 引用预定义的 Jira 连接
ticket_id (str | None) – 要监控的事务 ID
field (str | None) – 要监控的事务字段
expected_value (str | None) – 字段的预期值
result_processor – 返回布尔值并作为 sensor 响应的函数

template_fields: collections.abc.Sequence[str] = ('ticket_id',)[源代码]¶

jira_conn_id = 'jira_default'[源代码]¶

ticket_id = None[源代码]¶

field = None[源代码]¶

expected_value = None[源代码]¶

poke(context)[源代码]¶

派生此类时重写。

issue_field_checker(jira_result)[源代码]¶

使用不同条件检查事务以准备评估 sensor。