OK

longvideoapi/server/longvideoapi_docker.sh

@@ -1,100 +0,0 @@
-#/bin/bash
-cid=0
-httpcode=000
-check_docker(){
-	echo "-----------------------------"
-   	echo "检查Docker安装环境......"
-	echo "-----------------------------"
-  	 docker -v
-	if [ $? -eq  0 ]; then
-		echo "检查到Docker已安装!"
-		echo "-----------------------------"
-		service docker restart
-		sleep  5
-	else
-		echo "安装docker环境..."
-		echo "-----------------------------"
-		yum install  docker     -y
-		echo "安装docker环境...安装完成!"
-		echo "-----------------------------"
-    service docker start
-		sleep  5
-	fi
-}
-check_up(){
-	echo "-----------------------------"
-	echo "正在确认服务是否完成启动！"
-	while  [ $httpcode != 200 ]
-	do
-		httpcode=`curl -I -m 10 -o /dev/null -s -w %{http_code}  http://localhost:8182/longvideoapi/test`
-       		echo  -en  ". "
-       		sleep 2
-   	 done
-	echo  " "
-	echo   “请求返回值：  $httpcode  服务器启动完成”
-	echo "-----------------------------"  
-
-
-
-}
-
-
-
-stop(){
-         python  /home/sh/update_longvideoapi.py  0
-	echo "-----------------------------"
-	echo "检查vlogapi容器是否存在"
-	echo "-----------------------------"
-
-      
-        docker  stop  $(docker ps -a|grep -v IMAGE|awk  '{print $1}')
-        docker  rm  -f $(docker ps -a|grep -v IMAGE|awk  '{print $1}')
-        docker  rmi  registry-vpc.cn-hangzhou.aliyuncs.com/stuuudy/vlogapi:latest
-}
-start(){
-	cid=`docker ps |grep  "vlogapi:latest"|grep -v grep|awk  '{print $1}'`
-	if [ $cid  ];then
-		echo "vlogapi already started ！"
-		echo "-----------------------------"
-	else
-
-		docker login --username=stuuudys --password=Qingqu@2019   registry-vpc.cn-hangzhou.aliyuncs.com
-		#docker run --cap-add=SYS_PTRACE  -d -it  -p 8080:8185 --restart=always  registry-vpc.cn-hangzhou.aliyuncs.com/stuuudy/longvideoapi:latest
-                docker run --cap-add=SYS_PTRACE  -d -it   --name  vlogapi   --restart=always --network host    registry-vpc.cn-hangzhou.aliyuncs.com/stuuudy/vlogapi:latest
-	       check_up
-               python  /home/sh/slb_scan.py
-	
-	fi
-
-}
-
-
-
-  case "$1" in
-   'start')
-      start
-      ;;
-   'stop')
-     stop
-     ;;
-   'restart')
-     stop
-     start
-     ;;
-   'rollback')
-     rollback
-     ;;
-   'deploy')
-     deploy
-     ;;
-   'status')
-     check_up
-     ;;
-   'info')
-     info
-     ;;
-  *)
-     echo "Usage: $0 {start|stop|restart|rollback|deploy|status|info}"
-     exit 1
-;;
-esac

longvideoapi/server/restart.sh

@@ -0,0 +1,29 @@
+#/bin/bash
+
+stop(){
+      
+        docker  stop  $(docker ps -a|grep  "longvideoapi:latest"|grep -v grep|awk  '{print $1}')
+}
+start(){
+	cid=`docker ps   -a |grep  "longvideoapi:latest"|grep -v grep|awk  '{print $1}'`
+       docker  start $cid
+}
+
+
+
+  case "$1" in
+   'start')
+      start
+      ;;
+   'stop')
+     stop
+     ;;
+   'restart')
+     stop
+     start
+     ;;
+  *)
+     echo "Usage: $0 {start|stop|restart}"
+     exit 1
+;;
+esac

longvideoapi/server/slb_scan.py

@@ -1,138 +0,0 @@
-#!/usr/bin/python
-# coding: utf-8
-import sys
-from aliyunsdkcore import client
-from aliyunsdkcore.client import AcsClient
-from aliyunsdkcore.request import CommonRequest
-from aliyunsdkecs.request.v20140526.DescribeInstancesRequest import DescribeInstancesRequest
-from aliyunsdkslb.request.v20140515.DescribeLoadBalancerAttributeRequest import DescribeLoadBalancerAttributeRequest
-import json
-import socket
-import  time
-
-AccessKey = 'LTAIuPbTPL3LDDKN'
-AccessSecret = 'ORcNedKwWuwVtcq4IRFtUDZgS0b1le'
-RegionId = 'cn-hangzhou'
-# 压力测试环境   SlbId
-#SlbId = 'lb-bp12usgpoh04qsa6pw42r'
-#longvideoapi-online  SlbId
-SlbId = 'lb-bp1d6hp2ctotgt870miav'
-
-clt = client.AcsClient (AccessKey, AccessSecret, RegionId)
-Host = socket.gethostname ()
-
-
-exit = -1
-def setServerWeight(BackendServers):
-    request = CommonRequest ()
-    request.set_accept_format ('json')
-    request.set_domain ('slb.aliyuncs.com')
-    request.set_version ('2014-05-15')
-    request.set_method ('POST')
-    request.set_action_name ('SetBackendServers')
-    request.add_query_param ('BackendServers', BackendServers)
-    request.add_query_param ('LoadBalancerId', SlbId)
-    # print   BackendServers
-    response = clt.do_action (request)
-    return json.loads (response)
-
-
-def get_host_ip():
-    """
-    查询本机ip地址
-    :return: ip
-    """
-    try:
-        s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
-        s.connect(('8.8.8.8', 80))
-        ip = s.getsockname()[0]
-        #ip = "192.168.201.80"
-    finally:
-        s.close()
-        return ip
-
-
-def  query_slb(instance_id):
-    global exit
-    request = DescribeLoadBalancerAttributeRequest ()
-    request.set_accept_format ('json')
-    request.set_LoadBalancerId (SlbId)
-    times = 0
-    while  times < 300:
-        try:
-            response = clt.do_action_with_exception (request)
-            res_result = json.loads(response)
-
-            if  res_result["BackendServers"]["BackendServer"]:
-                for  i  in range(len(res_result["BackendServers"]["BackendServer"])):
-                    slb_instance_id = res_result["BackendServers"]["BackendServer"][i]["ServerId"]
-                    if  instance_id == slb_instance_id :
-                        print("服务器已经挂载")
-                        exit = 1
-            if  exit == 1:
-                break
-            time.sleep(2)
-            times += 1
-        except Exception as e:
-            print(e)
-            print("负载均衡信息获取失败")
-
-    return   res_result
-
-
-if __name__ == "__main__":
-
-    ip = get_host_ip()
-
-    ##获取instarnceid
-    ip_add = []
-    ip_add.append(ip)
-    request = DescribeInstancesRequest ()
-    request.set_PrivateIpAddresses (ip_add)
-    response = clt.do_action_with_exception (request)
-    #print(response)
-    result = json.loads(response)
-    instance_id = result["Instances"]["Instance"][0]["InstanceId"]
-    print(instance_id)
-    back_servers = [{"ServerId": '', "Weight": ''}]
-    back_servers[0]["ServerId"] = instance_id
-    query_slb (instance_id)
-    print(exit)
-
-
-    if  exit == 1 :
-        weight = 20
-        while weight <= 100:
-            back_servers[0]["Weight"] = weight
-            print(back_servers)
-            try:
-                res_slb = setServerWeight ( back_servers)
-                request = DescribeLoadBalancerAttributeRequest ()
-                request.set_accept_format ('json')
-                request.set_LoadBalancerId (SlbId)
-                response = clt.do_action_with_exception (request)
-                res_result = json.loads (response)
-
-                if res_result["BackendServers"]["BackendServer"]:
-                    for i in range (len (res_result["BackendServers"]["BackendServer"])):
-                        slb_instance_id = res_result["BackendServers"]["BackendServer"][i]["ServerId"]
-                        if instance_id == slb_instance_id:
-                            weight_now = res_result["BackendServers"]["BackendServer"][i]["Weight"]
-                            print (weight_now)
-                if  weight == weight_now :
-                    print("权重修改成功")
-                else:
-                    print("权重修改失败，重试.......")
-                    res_slb = setServerWeight (back_servers)
-                print(res_slb["BackendServers"]["BackendServer"])
-            except:
-                print("负载均衡权重修改失败")
-            weight += 20
-            time.sleep(10)
-    else:
-        print("服务器未挂载，请尽快查看具体情况")
-
-
-
-
-