From e394fc8e443920fff599ac43b1da2eb6f3ce56e8 Mon Sep 17 00:00:00 2001
From: liwei1dao <liwei1dao@gmail.com>
Date: Tue, 31 May 2022 16:59:28 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E9=85=8D=E7=BD=AE=E4=BB=A5?=
 =?UTF-8?q?=E5=8F=8Apyhont=20=E5=B7=A5=E5=85=B7=E8=84=9A=E6=9C=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 bin/conf/worker_1.yaml |  4 ++--
 py_consul.py           | 35 +++++++++++++++++++++++++++++++++++
 2 files changed, 37 insertions(+), 2 deletions(-)
 create mode 100644 py_consul.py

diff --git a/bin/conf/worker_1.yaml b/bin/conf/worker_1.yaml
index 3526d41a4..5d4081212 100644
--- a/bin/conf/worker_1.yaml
+++ b/bin/conf/worker_1.yaml
@@ -1,4 +1,4 @@
-id : "worker_2"                                 #服务的唯一id 在集群服务下不能重复即可 建议配置文件名与服务id一致
+id : "worker_1"                                 #服务的唯一id 在集群服务下不能重复即可 建议配置文件名与服务id一致
 ip : "127.0.0.1"                                #运行主机Ip 集群通信中 按ip节点通行的查询字段 此字段可以注释掉 注释后取当前运行主机公网ip地址
 port : 9568                                     #服务监听端口 RPC服务
 tag : "dreamfactory"                                    #服务集群标签 相同标签 且sys.registry 和 sys.rpc 配置一致 即可互相发现和通信
@@ -9,7 +9,7 @@ version : 1.0                                   #服务版本 多服务器相同
 #系统配置
 sys:
   log:  #日志系统                            
-    FileName: "./log/worker_2.log"        #日志文件存放地址
+    FileName: "./log/worker_1.log"        #日志文件存放地址
     Loglevel: 0                         #日志文件输出级别
     LogMaxSize: 128                     #日志文件最大Size
     LogMaxAge: 7                        #日志文件最多保留天数
diff --git a/py_consul.py b/py_consul.py
new file mode 100644
index 000000000..2a0ef20ea
--- /dev/null
+++ b/py_consul.py
@@ -0,0 +1,35 @@
+#!/usr/bin/env python
+ 
+# encoding: utf-8
+import requests
+import json
+ 
+host = '10.0.0.9'
+port = 8500
+ 
+#consul中微服务名称
+serviceNames='dreamfactory'
+ 
+def get_service():
+    url = 'http://'+host+':'+str(port)+'/v1/agent/services'
+    data = requests.get(url).json()    
+    jsonStr = json.dumps(data)
+    print('json '+jsonStr)
+    keys = []
+    for k in data:    
+        serviceName=data[k]['Service']
+        if serviceName in serviceNames:
+             print(data[k]['Service'])
+             print(data[k]['ID'])
+             keys.append(k)
+    return keys
+ 
+def del_service(keys):
+    url = 'http://'+host+':'+str(port)+'/v1/agent/service/deregister/'
+    for sid in keys:
+        requests.put(url+sid)
+        print('删除 '+sid)
+ 
+if __name__ == '__main__':
+    keys = get_service()
+    del_service(keys)
\ No newline at end of file