airflow.providers.openfaas.hooks.openfaas

Attributes

OK_STATUS_CODE

Classes

OpenFaasHook

Interact with OpenFaaS to query, deploy, invoke and update function.

Module Contents

airflow.providers.openfaas.hooks.openfaas.OK_STATUS_CODE = 202[source]
class airflow.providers.openfaas.hooks.openfaas.OpenFaasHook(function_name=None, conn_id='open_faas_default', *args, **kwargs)[source]

Bases: airflow.providers.common.compat.sdk.BaseHook

Interact with OpenFaaS to query, deploy, invoke and update function.

Parameters:

  • function_name – Name of the function, Defaults to None

  • conn_id (str) – OpenFaaS connection to use, defaults to open_faas_default for example host : http://openfaas.faas.com

conn_name_attr = 'conn_id'[source]
default_conn_name = 'open_faas_default'[source]
conn_type = 'openfaas'[source]
hook_name = 'OpenFaaS'[source]
GET_FUNCTION = '/system/function/'[source]
INVOKE_ASYNC_FUNCTION = '/async-function/'[source]
INVOKE_FUNCTION = '/function/'[source]
DEPLOY_FUNCTION = '/system/functions'[source]
UPDATE_FUNCTION = '/system/functions'[source]
classmethod get_ui_field_behaviour()[source]

Return custom field behaviour.

function_name = None[source]
conn_id = 'open_faas_default'[source]
get_conn()[source]

Return connection for the hook.

deploy_function(overwrite_function_if_exist, body)[source]

Deploy OpenFaaS function.

invoke_async_function(body)[source]

Invoke function asynchronously.

invoke_function(body)[source]

Invoke function synchronously. This will block until function completes and returns.

update_function(body)[source]

Update OpenFaaS function.

does_function_exist()[source]

Whether OpenFaaS function exists or not.

Was this entry helpful?