python flask服务如何注册到nacos

简介: 一文讲清楚python flask服务如何注册到nacos

shigen坚持更新文章的博客写手,擅长Java、python、vue、shell等编程语言和各种应用程序、脚本的开发。记录成长,分享认知,留住感动。
个人IP:shigen

背景

shigen之前遇到了一个服务,需要结合nacos+ Spring security实现服务的负载均衡。其中最为重要的就是python服务自己注册到nacos上,趁着闲暇时间,来研究了一番。

nacos官网中提到了【其它语言的sdk】:

nacos其它语言SDK

点击【python】就跳转到了GitHub。

官网内容

看着好像也没说的很清楚,我们自己来调用SDK实现一下。

代码实现

首先确保nacos服务启动了,shigen这里用的docker-compose的方式启动的:

nacos启动

对应的docker-compose文件如下:

version: '3'
services:
  nacos-standalone:
    image: nacos/nacos-server:v2.1.2-slim
    container_name: nacos-server
    ports:
      - 8848:8848
      - 9848:9848
      - 9849:9849
    environment:
      - 'MODE=standalone'
      - 'TIME_ZONE=Asia/Shanghai'
    volumes:
      - ./conf:/home/nacos/conf
      - ./logs:/home/nacos/logs
      - ./data:/home/nacos/data

代码可以参考shigen的gitee-cloud-patform

首先下载依赖:

pip install nacos-sdk-python

安装依赖

依赖安装完成,就可以继续写代码了,主要是注册上服务和发送心跳。

最开始,shigen尝试了官方的SDK,总是出现异常,最后看了一下官方的描述:

Supported Python version:

Python 2.7 Python 3.6 Python 3.7

Supported Nacos version

Nacos 0.8.0 ~ 1.3.2

好家伙,我忽视了nacos的版本,注意,我的nacos是这样的:nacos/nacos-server:v2.1.2-slim,直接2.0+,不适配。害得我折腾了一下午,最后和伙伴出去跑步了,心里一想,我真是钻牛角尖。服务的注册也不是我的首要任务,实在不行,用官方的API照样可以注册上去。

于是,回来尝试了一下:

import sys
# 用于异步处理心跳检测
import threading
import time
from typing import NoReturn

import requests
from flask import Flask, jsonify, request

app = Flask(__name__)


# 服务注册
def service_register(service_name: str, ip: str, port: int):
    url = f"http://127.0.0.1:8848/nacos/v1/ns/instance?serviceName={service_name}&ip={ip}&port={port}"
    res = requests.post(url)
    print(f"完成注册: {res.status_code}")


# 心跳检测
def service_beat(service_name: str, ip: str, port: int) -> NoReturn:
    while True:
        url = f"http://127.0.0.1:8848/nacos/v1/ns/instance/beat?serviceName={service_name}&ip={ip}&port={port}"
        res = requests.put(url)
        print(f"心跳检测中... 响应状态码: {res.status_code}")
        time.sleep(5)


@app.route('/get_server_info', methods=['GET'])
def get_server_info():
    server_ip = request.host.split(':')[0]
    server_port = request.host.split(':')[1]

    response = {
   
   'ip': server_ip, 'port': server_port}
    return jsonify(response)


if __name__ == '__main__':
    if len(sys.argv) > 1:
        port = int(sys.argv[1])
    else:
        port = 10000
    service_name = 'python-server'
    ip = '127.0.0.1'
    service_register(service_name, ip, port)
    # 5 秒后执行心跳检测
    threading.Timer(5, service_beat(service_name, ip, port)).start()
    app.run()

参考文章:spring boot和flask整合nacos

特意的留了一个命令行参数作为服务的端口号,这样的话,副本数就很好控制了。

控制台操作一下:

服务的启动

注意:服务在第一次启动注册之后,需要不断的对nacos发送心跳,表明服务的存活。

最后实现的效果是这样的:

实现效果

那接下来就是网关层的调用和负载均衡了,这个下期再讲。

与shigen一起,每天不一样!

目录
相关文章
|
7天前
|
API 数据库 数据安全/隐私保护
Flask框架在Python面试中的应用与实战
【4月更文挑战第18天】Django REST framework (DRF) 是用于构建Web API的强力工具,尤其适合Django应用。本文深入讨论DRF面试常见问题,包括视图、序列化、路由、权限控制、分页过滤排序及错误处理。同时,强调了易错点如序列化器验证、权限认证配置、API版本管理、性能优化和响应格式统一,并提供实战代码示例。了解这些知识点有助于在Python面试中展现优秀的Web服务开发能力。
31 1
|
7天前
|
安全 Linux Nacos
如何使用公网地址远程访问内网Nacos UI界面查看注册服务
如何使用公网地址远程访问内网Nacos UI界面查看注册服务
26 0
|
1天前
|
应用服务中间件 nginx Docker
使用 Python Flask 创建简易文件上传服务
在平时工作中,文件上传是一项常见的需求,例如将应用异常时通过脚本生成的dump文件收集起来进行分析,但实现起来却可能相当复杂。幸运的是,Flask框架提供了一种简单而高效的方式来处理文件上传,代码不到100行。在本文中,我们将探讨如何使用Flask实现文件上传功能,编写Dockerfile将应用程序通过docker部署。
|
2天前
|
缓存 API 数据库
构建高效Python Web应用:Flask框架与RESTful API设计原则
【5月更文挑战第20天】 在现代Web开发中,构建一个轻量级且高效的后端服务至关重要。本文将深入探讨如何使用Python的Flask框架结合RESTful API设计原则来创建可扩展和易于维护的Web应用程序。我们将通过分析Flask的核心特性,以及如何利用它来实现资源的合理划分、接口的版本控制和请求处理优化等,来指导读者打造高性能的API服务。文中不仅提供了理论指导,还包括了实践案例,旨在帮助开发者提升开发效率,并增强应用的稳定性和用户体验。
|
5天前
|
缓存 监控 API
利用Python构建高性能的Web API后端服务
随着微服务架构的普及和RESTful API的广泛应用,构建高性能、可扩展的Web API后端服务变得尤为重要。本文将探讨如何利用Python这一强大且灵活的语言,结合现代Web框架和工具,构建高效、可靠的Web API后端服务。我们将分析Python在Web开发中的优势,介绍常用的Web框架,并通过实际案例展示如何设计并实现高性能的API服务。
|
7天前
|
存储 缓存 监控
利用Python和Flask构建RESTful API的实战指南
在当今的软件开发中,RESTful API已成为前后端分离架构中的核心组件。本文将带你走进实战,通过Python的Flask框架,一步步构建出高效、安全的RESTful API。我们将从项目初始化、路由设置、数据验证、错误处理到API文档生成,全方位地探讨如何构建RESTful API,并给出一些实用的最佳实践和优化建议。
|
7天前
|
开发框架 安全 搜索推荐
如何使用vscode启动Flask并实现无公网IP远程访问内网服务
如何使用vscode启动Flask并实现无公网IP远程访问内网服务
22 0
|
7天前
|
人工智能 算法 API
【Python+微信】【企业微信开发入坑指北】0. 创建自建应用并接入自己的服务
【Python+微信】【企业微信开发入坑指北】0. 创建自建应用并接入自己的服务
23 0
【Python+微信】【企业微信开发入坑指北】0. 创建自建应用并接入自己的服务
|
7天前
|
SQL 中间件 API
Flask框架在Python面试中的应用与实战
【4月更文挑战第18天】**Flask是Python的轻量级Web框架,以其简洁API和强大扩展性受欢迎。本文深入探讨了面试中关于Flask的常见问题,包括路由、Jinja2模板、数据库操作、中间件和错误处理。同时,提到了易错点,如路由冲突、模板安全、SQL注入,以及请求上下文管理。通过实例代码展示了如何创建和管理数据库、使用表单以及处理请求。掌握这些知识将有助于在面试中展现Flask技能。**
20 1
Flask框架在Python面试中的应用与实战
|
关系型数据库 数据库 开发工具
利用Flask + python3.6+MYSQL编写一个简单的评论模块。
利用flask + python3.6+MYSQL编写一个简单的评论模块。输入内容提交后,会显示在页面上。 发送并接受评论框的数据 在falsk返回首页的函数前,加入methods属性。 @app.route("/", methods=["GET", "POST"]) 两种接收数据的方式 暂时性的保存,并显示在网页上.in-memory storage 主程序如下,每当程序reload时候,comments会被初始化。
2672 0