python技术简介（三）

# 安装
pip install etcd3

# 方法
#  连接到 etcd 服务器
etcd3.client(host, port)
# 设置键值
put(key, value)
# 获取键值
get(key)
# 删除键值
delete(key)
# 获取以指定前缀开头的所有键值
get_prefix(prefix)
# 删除以指定前缀开头的所有键值
delete_prefix(prefix)
# 监听键值变化
watch(key)

import etcd3
import socket
import uuid

def register_service(service_name, host, port):
    etcd = etcd3.client()
    service_id = str(uuid.uuid4())
    key = f'/services/{service_name}/{service_id}'
    value = f'{host}:{port}'
    etcd.put(key, value)
    print(f'Service {service_name} registered with ID {service_id} at {host}:{port}')
    return service_id

def unregister_service(service_name, service_id):
    etcd = etcd3.client()
    key = f'/services/{service_name}/{service_id}'
    etcd.delete(key)
    print(f'Service {service_name} unregistered with ID {service_id}')

# 获取本机IP地址
hostname = socket.gethostname()
host_ip = socket.gethostbyname(hostname)

# 注册服务
service_id = register_service('my_service', host_ip, 8080)

# 停止服务时取消注册
# unregister_service('my_service', service_id)


def discover_services(service_name):
    etcd = etcd3.client()
    instances = etcd.get_prefix(f'/services/{service_name}')
    services = []
    for value, metadata in instances:
        service_info = value.decode('utf-8')
        services.append(service_info)
    return services

# 发现服务
services = discover_services('my_service')
print(f'Discovered services: {services}')