airflow.providers.edge3.cli.api_client¶

属性¶

`logger`
`API_RETRIES`
`API_RETRY_WAIT_MIN`
`API_RETRY_WAIT_MAX`

函数¶

`worker_register`(hostname, state, queues, sysinfo)	向 Edge API 注册 worker。
`worker_set_state`(hostname, state, jobs_active, queues, ...)	更新中心站点中 worker 的状态，从而隐式地进行心跳。
`jobs_fetch`(hostname, queues, free_concurrency)	获取一个将在边缘 worker 上执行的任务。
`jobs_set_state`(key, state)	设置任务的状态。
`logs_logfile_path`(task)	详细说明任务执行时预期的路径和文件名。
`logs_push`(task, log_chunk_time, log_chunk_data)	将增量日志块从边缘 Worker 推送到中心站点。

模块内容¶

airflow.providers.edge3.cli.api_client.logger[source]¶

airflow.providers.edge3.cli.api_client.API_RETRIES[source]¶

airflow.providers.edge3.cli.api_client.API_RETRY_WAIT_MIN[source]¶

airflow.providers.edge3.cli.api_client.API_RETRY_WAIT_MAX[source]¶

airflow.providers.edge3.cli.api_client.worker_register(hostname, state, queues, sysinfo)[source]¶

向 Edge API 注册 worker。

airflow.providers.edge3.cli.api_client.worker_set_state(hostname, state, jobs_active, queues, sysinfo, maintenance_comments=None)[source]¶

更新中心站点中 worker 的状态，从而隐式地进行心跳。

airflow.providers.edge3.cli.api_client.jobs_fetch(hostname, queues, free_concurrency)[source]¶

获取一个将在边缘 worker 上执行的任务。

airflow.providers.edge3.cli.api_client.jobs_set_state(key, state)[source]¶

设置任务的状态。

airflow.providers.edge3.cli.api_client.logs_logfile_path(task)[source]¶

详细说明任务执行时预期的路径和文件名。

airflow.providers.edge3.cli.api_client.logs_push(task, log_chunk_time, log_chunk_data)[source]¶

将增量日志块从边缘 Worker 推送到中心站点。