airflow.contrib.hooks.openfaas_hook

Module Contents

airflow.contrib.hooks.openfaas_hook.OK_STATUS_CODE = 202

class airflow.contrib.hooks.openfaas_hook.OpenFaasHook(function_name=None, conn_id='open_faas_default', *args, **kwargs)

Bases: airflow.hooks.base_hook.BaseHook

Interact with Openfaas to query, deploy, invoke and update function

Parameters

• function_name – Name of the function, Defaults to None

• conn_id (str) – openfass connection to use, Defaults to open_faas_default for example host : http://openfaas.faas.com, Conn Type : Http

GET_FUNCTION = /system/function/

INVOKE_ASYNC_FUNCTION = /async-function/

DEPLOY_FUNCTION = /system/functions

UPDATE_FUNCTION = /system/functions

get_conn(self)

deploy_function(self, overwrite_function_if_exist, body)

invoke_async_function(self, body)

update_function(self, body)

does_function_exist(self)