airflow.providers.http.triggers.http

Module Contents

Classes

HttpTrigger

HttpTrigger run on the trigger worker.
class airflow.providers.http.triggers.http.HttpTrigger(http_conn_id='http_default', auth_type=None, method='POST', endpoint=None, headers=None, data=None, extra_options=None)[source]

Bases: airflow.triggers.base.BaseTrigger

HttpTrigger run on the trigger worker.

Parameters

  • http_conn_id (str) – http connection id that has the base API url i.e https://www.google.com/ and optional authentication credentials. Default headers can also be specified in the Extra field in json format.

  • auth_type (Any) – The auth type for the service

  • method (str) – the API method to be called

  • endpoint (str | None) – Endpoint to be called, i.e. resource/v1/query?.

  • headers (dict[str, str] | None) – Additional headers to be passed through as a dict.

  • data (Any) – Payload to be uploaded or request parameters.

  • extra_options (dict[str, Any] | None) – Additional kwargs to pass when creating a request. For example, run(json=obj) is passed as aiohttp.ClientSession().get(json=obj). 2XX or 3XX status codes

serialize()[source]

Serializes HttpTrigger arguments and classpath.

async run()[source]

Makes a series of asynchronous http calls via an http hook.

Was this entry helpful?