liqian 2 gadi atpakaļ
vecāks
revīzija
1580b04fcb
1 mainītis faili ar 18 papildinājumiem un 0 dzēšanām
  1. 18 0
      rov-sever/server/ess_instance_rov_server_new.py

+ 18 - 0
rov-sever/server/ess_instance_rov_server_new.py

@@ -18,6 +18,7 @@ from aliyunsdkecs.request.v20140526.DescribeNetworkInterfacesRequest import Desc
 from aliyunsdkslb.request.v20140515.AddBackendServersRequest import AddBackendServersRequest
 from aliyunsdkecs.request.v20140526.RunCommandRequest import RunCommandRequest
 from aliyunsdkcore.request import CommonRequest
+from aliyunsdkecs.request.v20140526.SendFileRequest import SendFileRequest
 
 
 logging.basicConfig(level=logging.INFO,
@@ -194,6 +195,22 @@ def getIpaddr(instance_id):
     return ipaddr
 
 
+def send_file_to_ecs(instance_id_list):
+    content = """#!/bin/bash
+docker login --username=stuuudys --password=Qingqu@2019   registry.piaoquantv.com
+docker run  -d -it   --network=host  --name=rov-server   registry.piaoquantv.com/piaoquan/rov-server:latest
+"""
+    target_dir = '/home/sh'
+    name = 'rov_server_start_new.sh'
+    request = SendFileRequest()
+    request.set_Content(content)
+    request.set_TargetDir(target_dir)
+    request.set_Name(name)
+    request.set_Overwrite(True)
+    request.set_InstanceIds(instance_id_list)
+    response = clt.do_action_with_exception(request)
+
+
 def _execute_request(request):
     response = _send_request(request)
     if response.get('Code') is None:
@@ -205,6 +222,7 @@ def _execute_request(request):
 
         logging.info(f"{instance_ids} is running")
         time.sleep(60)
+        send_file_to_ecs(instance_id_list=instance_ids)
         runCommand(instance_ids)
 
         for instance_id in instance_ids: