airflow.providers.openfaas.hooks.openfaas

Module Contents

Classes

OpenFaasHook

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

Attributes

OK_STATUS_CODE

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.hooks.base.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, Connection Type : Http

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]
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?