`airflow.contrib.hooks.openfaas_hook`¶

Module Contents¶

airflow.contrib.hooks.openfaas_hook.OK_STATUS_CODE = 202[source]¶

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

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/[source]¶

INVOKE_ASYNC_FUNCTION = /async-function/[source]¶

DEPLOY_FUNCTION = /system/functions[source]¶

UPDATE_FUNCTION = /system/functions[source]¶

get_conn(self)[source]¶

deploy_function(self, overwrite_function_if_exist, body)[source]¶

invoke_async_function(self, body)[source]¶

update_function(self, body)[source]¶

does_function_exist(self)[source]¶

Was this entry helpful?