blob: 6561c01dc214473a6f679ac166e806d25632e883 [file] [log] [blame]
:mod:`airflow.operators.http_operator`
======================================
.. py:module:: airflow.operators.http_operator
Module Contents
---------------
.. py:class:: SimpleHttpOperator(endpoint, method='POST', data=None, headers=None, response_check=None, extra_options=None, xcom_push=False, http_conn_id='http_default', log_response=False, *args, **kwargs)
Bases: :class:`airflow.models.BaseOperator`
Calls an endpoint on an HTTP system to execute an action
:param http_conn_id: The connection to run the operator against
:type http_conn_id: str
:param endpoint: The relative part of the full url. (templated)
:type endpoint: str
:param method: The HTTP method to use, default = "POST"
:type method: str
:param data: The data to pass. POST-data in POST/PUT and params
in the URL for a GET request. (templated)
:type data: For POST/PUT, depends on the content-type parameter,
for GET a dictionary of key/value string pairs
:param headers: The HTTP headers to be added to the GET request
:type headers: a dictionary of string key/value pairs
:param response_check: A check against the 'requests' response object.
Returns True for 'pass' and False otherwise.
:type response_check: A lambda or defined function.
:param extra_options: Extra options for the 'requests' library, see the
'requests' documentation (options to modify timeout, ssl, etc.)
:type extra_options: A dictionary of options, where key is string and value
depends on the option that's being modified.
:param xcom_push: Push the response to Xcom (default: False).
If xcom_push is True, response of an HTTP request will also
be pushed to an XCom.
:type xcom_push: bool
:param log_response: Log the response (default: False)
:type log_response: bool
.. attribute:: template_fields
:annotation: = ['endpoint', 'data', 'headers']
.. attribute:: template_ext
:annotation: = []
.. attribute:: ui_color
:annotation: = #f4a460
.. method:: execute(self, context)