人工智能与云盘算

项目要求
一个简单的集群。您须要在此项目中创建盘算机集群。这些呆板是 docker 容器。集群管理器是一个 Python 步伐。聚集的状态将写入文件。
盼望通过这个 Python 文件，起首它可以大概通过获取输入来得到要创建的集群中包罗的容器数目，并与用户举行交互（用户可以实验此集群的扩容和缩容等操纵），然后你可以查询他的状态列表，即该集群的状态。比方，有多少容器是运动状态的，有多少容器是克制状态的。你须要通过 Python 脚本将集群的状态写入文件。
实现功能：

  

• 创建：通过获取输入，与用户举行交互（用户可以实验此集群的扩容和缩容等操纵），以得到要创建的集群中包罗的容器数目。  
  
• 启动容器：设置容器ID。  
  
• 实验下令：运行一些下令。  
  
• 克制容器。  
  
• 完全删除容器。  
  
• 扩容：在原有底子上增长容器数目，可以汲取下令，并根据下令确定增长的容器数目。  
  
• 缩容：淘汰容器数目。  
  
• 删除集群中的全部容器。
  

代码实现：

一个完备的 ClusterManager 类和一个包罗主循环的 if __name__ == "__main__": 部分。每个上述方法都放入该类中。这些方法包罗：
创建集群 (create_cluster(self)):

根据用户输入，可以创建指定命量的容器，利用循环，利用 create 函数，每个运行一个交互式 shell (tty=True)，并将容器对象添加到 self.containers 列表中。

1. import docker
3. # 定义要运行的镜像名称和命令
4. image_name = "alpine"

复制代码

1. self.client = docker.from_env()
3.  container = self.client.containers.create("alpine", "sh",tty=True, detach=True)

复制代码

查询状态 (query_status(self)):

查询容器集群的状态，列出每个容器的 ID 和状态。通过遍历 self.containers 列表中的每个容器对象，利用 container.reload() 更新容器状态，然后打印每个容器的 ID 和状态。

1. container.reload()
2.             if container.status == "running":

复制代码

扩容 (scale_up(self, count)):

扩展容器集群，向集群中添加指定命量的新容器，每个运行一个交互式 shell (sh)。利用循环创建指定命量的容器，每个运行一个交互式 shell (tty=True)，并将容器对象添加到 self.containers 列表中。

1. container = self.client.containers.create("alpine", "sh", tty=True, detach=True)

复制代码

缩容 (scale_down(self, count)):

缩小容器集群，从集群中移除指定命量的容器并克制它们。利用循环从 self.containers 列表中移除指定命量的容器并克制它们。

1. container = self.containers.pop()
2.             container.stop()

复制代码

克制容器 (stop_container(self, container_id)):

克制具有指定ID的容器，利用容器ID获取容器对象，然后调用 container.stop() 方法克制容器。

1. container = self.client.containers.get(container_id)
2.             container.stop()

复制代码

删除容器 (delete_container(self, container_id)):

删除具有指定ID的容器，利用容器ID获取容器对象，然后调用 container.remove() 方法删除容器并从 self.containers 列表中移除容器对象。

1. container = self.client.containers.get(container_id)
2.             container.remove()
3.             self.containers.remove(container)

复制代码

运行下令 (run_command(self, container_id, command)):

在具有指定ID的容器中实验下令，利用容器的ID获取容器对象，等候容器状态变为“running”，然后利用 container.exec_run(command) 实验给定下令。

1. response = container.exec_run(command)

复制代码

启动容器 (start_container(self, container_id)):

启动具有指定ID的容器，利用容器ID获取容器对象，然后调用 container.start() 方法启动已创建但已克制的容器。

1. container = self.client.containers.get(container_id)
2.             container.start()

复制代码

获取容器日志 (get_container_logs(self, container_id)):

获取具有指定ID的容器的日志，利用容器ID获取容器对象，然后调用 container.logs() 获取容器的日志并将日志解码为文本。

1. container = self.client.containers.get(container_id)
2.             logs = container.logs()

复制代码

注意事项：

  

• 镜像名称：我们的镜像默认利用“alpine”。  
  
• 分离模式：这是一个布尔值，指定是否在分离模式下运行容器。默认值为 True，这意味着容器将在配景运行。  
  
• 容器ID：运行下令的容器的 ID。容器的 ID 是完备的容器 ID。  
  
• 下令：在容器内实验的下令。比方："ls -l"。我们利用 echo "Hello, World!"。  
  
• 在 run_container 和 start_container 方法中，都有打印容器状态，由于在创建或启动容器时状态大概不会立即变为“running”，我们设置循环以确保我们的打印输出是运行状态。  
  
• 利用 manager.client.containers.prune() 确保容器列表是最新的。
  

1. import docker
3. # 定义要运行的镜像名称和命令
4. image_name = "alpine"
5. clas

复制代码