airflow.providers.openfaas.hooks.openfaas¶

属性¶

OK_STATUS_CODE

类¶

与 OpenFaaS 交互以查询、部署、调用和更新函数。

模块内容¶

airflow.providers.openfaas.hooks.openfaas.OK_STATUS_CODE = 202[源码]¶

class airflow.providers.openfaas.hooks.openfaas.OpenFaasHook(function_name=None, conn_id='open_faas_default', *args, **kwargs)[源码]¶

基类: airflow.hooks.base.BaseHook

与 OpenFaaS 交互以查询、部署、调用和更新函数。

参数:

function_name – 函数名称，默认为 None
conn_id (str) – 要使用的 openfaas 连接，默认为 open_faas_default，例如主机: http://openfaas.faas.com，连接类型: Http

GET_FUNCTION = '/system/function/'[源码]¶

INVOKE_ASYNC_FUNCTION = '/async-function/'[源码]¶

INVOKE_FUNCTION = '/function/'[源码]¶

DEPLOY_FUNCTION = '/system/functions'[源码]¶

UPDATE_FUNCTION = '/system/functions'[源码]¶

function_name = None[源码]¶

conn_id = 'open_faas_default'[源码]¶

get_conn()[源码]¶: 返回 hook 的连接。

deploy_function(overwrite_function_if_exist, body)[源码]¶

部署 OpenFaaS 函数。

invoke_async_function(body)[源码]¶

异步调用函数。

invoke_function(body)[源码]¶

同步调用函数。这将阻塞直到函数完成并返回。

update_function(body)[源码]¶

更新 OpenFaaS 函数。

does_function_exist()[源码]¶

OpenFaaS 函数是否存在。

此条目是否有帮助？