在 Ubuntu 16.04 上自动启动 dask 分布式调度程序和工作程序

Question

我正在考虑在 Ubuntu 16.04 上自动启动和控制 dask 分布式调度程序和工作程序的不同方法。

目前我认为最相关的选项是使用 systemd 守护进程。这需要创建和安装unit files。

Systemd 要求单元文件应该有一个命令行来停止服务，在ExecStop 中设置。

重新加载配置的命令也很有用，但是，我不确定如何让 Python 重新导入模块，以及它是否比重新启动过程更简单。

看起来目前无法通过运行dask-scheduler 或dask-worker 命令来停止调度程序/工作人员，不是吗？我没有找到任何相关的命令行开关。

另一种选择是创建 PID 文件并使用标准的kill 命令，但是，Dask 分布式似乎不创建 PID 文件。我说的对吗？

Answer 1

如果您向dask-worker 或dask-scheduler 进程发送中断信号（例如当您使用Ctrl-C 时发生），它们将拦截它并干净地关闭。

我们目前不编写 PID 文件，但这很容易做到。如果您认为应该将其包含在项目中，我建议您 open an issue。与创建其他服务中常见的正确启动/停止命令相同。

Answer 2

最后，我来设置ExecStop=/bin/true。 Systemd 仍然成功停止并重新启动服务。

Current systemd manual 表示ExecStop 是可选的。