automatic import of python-sparrowcloud

3 files changed, 1106 insertions, 0 deletions

diff --git a/.gitignore b/.gitignore
index e69de29..639d175 100644
--- a/.gitignore
+++ b/.gitignore
@@ -0,0 +1 @@
+/sparrowcloud-4.1.1.tar.gz
diff --git a/python-sparrowcloud.spec b/python-sparrowcloud.spec
new file mode 100644
index 0000000..e1575a0
--- /dev/null
+++ b/python-sparrowcloud.spec
@@ -0,0 +1,1104 @@
+%global _empty_manifest_terminate_build 0
+Name:		python-sparrowcloud
+Version:	4.1.1
+Release:	1
+Summary:	基础Django和drf的微服务框架扩展
+License:	MIT
+URL:		https://gitee.com/sparrow614/sparrow_cloud
+Source0:	https://mirrors.nju.edu.cn/pypi/web/packages/fc/83/797480cb0b0794eee5efa7e95bea32e468c258c9f5da1318a97da487686b/sparrowcloud-4.1.1.tar.gz
+BuildArch:	noarch
+
+Requires:	python3-requests
+Requires:	python3-coreapi
+Requires:	python3-PyJWT
+Requires:	python3-openapi-codec
+Requires:	python3-dulwich
+Requires:	python3-pika
+Requires:	python3-cryptography
+Requires:	python3-opentracing
+Requires:	python3-jaeger-client
+
+%description
+    # 调用方式
+    from sparrow_cloud.message_service.sender import send_task
+    # 非延时消息
+    data = send_task(exchange=exchange, 
+                        routing_key=routing_key, 
+                        message_code=message_code, 
+                        retry_times=3,
+                        *args,
+                        **kwargs)
+    # 延时消息
+    data = send_task(exchange=exchange, 
+                    routing_key=routing_key, 
+                    message_code=message_code, 
+                    retry_times=3,
+                    delay=True,
+                    delay_time=200
+                    *args,
+                    **kwargs)
+    # ps:
+    #     exchange: 交换机
+    #     routing_key: 路由
+    #     message_code: 消息码
+    #     retry_times: 重试次数，非必填，默认重试次数为3次（每次间隔1秒）
+    #     delay: 是否发送延时消息，默认为False，表示立即发送。如果设为True，则根据delay_time来设定延时时间
+    #     delay_time: 延时时间，单位为秒
+```
+## rabbitmq_consumer
+> 麻雀任务消费
+> 1. 获取队列 2. 消费任务
+``` python
+    QUEUE_CONF_1 = {
+        "QUEUE": "",
+        "TARGET_FUNC_MAP": {
+            "ORDER_PAY_SUC_ONLINE": "path",
+        },
+    }
+    # ps:
+    #     QUEUE_CONF_1  # 队列的配置
+    #         QUEUE  # 队列名称
+    #         TARGET_FUNC_MAP  # 队列消费的任务（字典中的键为message code，对应的值为执行该消息的任务函数路径字符串）
+    # 调用方式：
+    # 注册服务到 settings 下的 INSTALLED_APPS中
+    INSTALLED_APPS = [
+        "sparrow_cloud.apps.message_service",
+    ]
+    # 调用命令：
+    python3 manage.py rabbitmq_consumer --queue QUEUE_CONF_1
+    # ps：
+    # 参数说明
+    #     --queue ： 指定发送队列配置名称， 参照settings中QUEUE_CONF_1配置         
+```
+## table_api
+> 接受查询条件返回django model 序列化后的数据
+> 分为server端和client端
+``` python
+ # server 端配置
+    # settings注册服务
+    INSTALLED_APPS = [
+        "sparrow_cloud.apps.table_api",
+    ]
+    # url配置
+    urlpatterns = [
+        path('table/api/', include("sparrow_cloud.apps.table_api.urls")),
+    ]
+ # client端调用 
+    from sparrow_cloud.restclient import rest_client
+    service_address = "sparrow-demo:8000"
+    payload = {
+        "app_lable_model":"app_lable.model",
+        "filter_condition":{"product_id":"74101"}
+    }
+    response = rest_client.get(service_address, api_path='/table/api/', json=payload)
+    #  返回的数据结构：{'code': 0, 'message': 'ok', 'data': [{}]}
+    # ps:
+    #     app_lable_model: app_name.model(app_name:INSTALLED_APPS里面注册的服务的名字, model:app_lable下的model名字，不区分大小写)
+    #     filter_condition: 过滤数据， kwargs
+    #     server端使用orm filter查询数据，当前版本不支持order_by
+```
+## API SCHEMA REGISTER
+>描述：主动注册API 描述到文档服务 配置schema_command 需要的参数
+``` python
+    # settings 配置:
+        # 注册服务到 settings 下的 INSTALLED_APPS中
+        INSTALLED_APPS = [
+            "sparrow_cloud.apps.schema_command",
+        ]
+        # 本服务配置
+        SERVICE_CONF = {
+            "NAME": "",  # 本服务的名称
+            "SECRET": ""
+        }
+    # 调用方式:
+        python3 manage.py register_api_schema
+    # 使用说明:
+    #     1、view支持@api_view注解方式，view_class支持GenericApiView，GenericViewSet及其子类
+    #     2、接口描述书写在view函数或者view_class的__doc__上，建议使用markdown格式，展示更美观
+```
+>接口描述代码示例
+```python
+from rest_framework.decorators import api_view
+from rest_framework.generics import  RetrieveUpdateDestroyAPIView
+from rest_framework import  generics
+from rest_framework.viewsets import ModelViewSet
+@api_view(('GET',))
+def get_user(request):
+    """
+    ### 获取用户信息 ####
+        请求参数 id, 用户id
+        返回
+            {
+                "user_id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+            }
+    """
+class UserApiView(RetrieveUpdateDestroyAPIView, generics.GenericAPIView):
+    """
+    get:
+        ### 查询用户信息 ###
+        请求参数 id, 用户id
+        返回
+            {
+                "id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+            }
+    delete:
+        ### 删除用户 ###
+        路径参数
+            id 用户id
+        返回
+            404 用户id不存在
+            204 删除成功
+    """
+    def put(self, request, *args, **kwargs):
+        """
+        ### 覆盖修改用户 ###
+            请求参数
+                {
+                 "id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+                }
+            返回 200 修改成功
+        """
+        return super(UserApiView, self).put(self, request, *args, **kwargs)
+class CarViewSet(ModelViewSet):
+    """
+    list: 分页查询车辆
+    retrieve:获取车辆信息
+    update: 覆盖修改车辆
+    partial_update: 部分修改车辆
+    create: 创建车辆
+    destroy: 删除车辆
+    """
+```
+## DING_TALK
+> ding_talk client SDK (将消息发送到钉钉群或微信群)
+```python
+    # 使用:
+    from sparrow_cloud.dingtalk.sender import send_message
+    from sparrow_cloud.authorization.token import get_app_token
+    app_token = get_app_token()
+    send_message(msg="test", code_list=["test", "test1"], channel="dingtalk", message_type="text", token=app_token)
+    # 成功返回： {'code': 0, 'message': 'success'}
+    # 错误返回： HTTPException
+    # 参数说明：
+    # msg:消息内容
+    # code_list: 消息群code
+    # channel: 消息发送的渠道("wechat", "dingtalk"), 默认 dingtalk
+    # message_type:微信支持("text", "markdown")消息类型, 默认 text, 钉钉只支持text类型
+```
+## ExceptionMiddleware
+> 中间件 (捕获程序异常，并发送消息到飞书)
+``` python
+    # settings 配置
+    MIDDLEWARE = [                 
+        "sparrow_cloud.middleware.exception.ExceptionMiddleware"  
+    ]
+```
+## LogMiddleware
+> 日志中间件（将istio-proxy层的request_id放入线程中，并透传到业务逻辑层，可通过 request.id 获取，与链路追踪中的request_id 一致）
+> 此中间件需要配合log_filter 使用，才能在每条业务逻辑日志中插入request_id, 如单独使用只能透request_id
+``` python
+    # settings 配置
+    MIDDLEWARE = [                 
+        "sparrow_cloud.middleware.log_middleware.RequestIDMiddleware"
+    ]
+```
+## log_filter
+> log_filter(自定义logfilter,从线程中获取request_id，从每条日志中打印出来)
+> 需要与LogMiddleware 中间件配合使用，否则不生效
+``` python 
+# log_settings 配置
+LOGGING = {
+    'version': 1,
+    'disable_existing_loggers': False,
+    'filters': {
+        # 新增的配置
+        'request_id': {
+            '()': 'sparrow_cloud.filter.log_filters.RequestIDFilter'
+        }
+    },
+    'handlers': {
+        'console': {
+            'level': 'DEBUG',
+            'class': 'logging.StreamHandler',
+            'formatter': 'standard',   # 需要修改的的配置
+            'filters': ['request_id'], # 增加的 log_filter 的配置
+        },
+        # 以访问控制服务的日志举例子
+        'access_control': {
+            'class': 'logging.handlers.RotatingFileHandler',
+            'filters': ['request_id'], # 增加的配置
+            'level': 'DEBUG',
+            'formatter': 'standard', # 修改为新增的formatters 配置
+            'filename': os.path.join(os.path.sep, BASE_DIR_LOG, 'access_control.log'),
+            'mode': 'a',
+            'maxBytes': 1024 * 1024 * 5,
+            'backupCount': 1, # 修改
+        },
+    },
+    'formatters': {
+        # 增加的配置
+        'standard': {
+                    'format': '%(levelname)s %(asctime)s %(request_id)s %(lineno)d %(name)s %(module)s %(funcName)s %(process)d %(thread)d %(message)s'
+                },
+    },
+    # sparrow_cloud 的日志
+    'sparrow_cloud': {
+        'handlers': ['console', 'sparrow_cloud'],
+        'level': 'DEBUG',
+        'propagate': False,
+    },
+    'access_control': {
+        'handlers': ['console', 'access_control'],
+        'level': 'DEBUG',
+        'propagate': False,
+    }
+}
+}
+```
+## ACCESS_CONTROL_VERIFY
+> access_control_verify decorators (访问控制验证)
+``` python
+    # settings 配置
+    SERVICE_CONF = {
+        "NAME": "",  # value为本服务的注册名称
+        "SECRET": "",
+    }
+    # 访问控制client端settings配置
+    # SC_SKIP_ACCESS_CONTROL:  是否跳过访问控制，  True：跳过， false：不跳过
+    # 使用方式
+    # 函数视图使用方式示例
+    from sparrow_cloud.access_control.decorators import access_control_fbv
+    @api_view(('POST', 'GET', 'PUT', 'DELETE'))
+    @access_control_fbv("permission_example1")  # 位置放到最下层
+    def test(request, *args, **kwargs):
+        return Response({"message": "ok"}, status=status.HTTP_200_OK)
+    # 类视图使用方式(全部方法都验证)
+    from sparrow_cloud.access_control.decorators import access_control_cbv_all
+    @access_control_cbv_all("permission_example1")
+    class ProductOperationList(generics.ListCreateAPIView):
+        """请求方法：GET/POST"""
+        pass
+    # 类视图使用方式(根据method验证)
+    from sparrow_cloud.access_control.decorators import access_control_cbv_method
+    RESOURCE = {
+    "post": "permission_example1", 
+    "get": "permission_example2"
+    }
+    @access_control_cbv_method(RESOURCE)
+    class ProductOperationList(generics.ListCreateAPIView):
+        """请求方法：GET/POST"""
+        pass
+```
+## get_user_token
+> get_user_token (获取用户token)
+```python
+    # 获取用户token
+    from sparrow_cloud.authorization.token import get_user_token
+    user_token = get_user_token(user_id="21424kvjbcdjslafds")
+```
+## get_app_token
+> get_app_token (获取服务token)
+```python
+    # 获取app token
+    from sparrow_cloud.authorization.token import get_app_token
+    app_token = get_app_token()
+```
+## app_message
+> app_message (发送消息到揽月app, 服务端未开源)
+```python
+    #目前支持的消息类型有：纯文本、图片，Markdown、文字card和图片card
+    # 发送图片消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "http://www.test.com/image.png"
+    res = send_message(msg_data=msg_data, code_type="test", content_type="image", msg_sender="麻雀", shop_id="2")
+    # 发送文本消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "文本消息"
+    res = send_message(msg_data=msg_data, code_type="test", nickname="文本消息携带字段")
+    # 发送文本card消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "卡片消息内容"
+    res = send_message(msg_data=msg_data, code_type="test", content_type="card_text", title="通知")
+    ##  参数说明
+        ## msg_data: 消息主体。填充待发送的消息格式msg中的data数据
+        ## code_type: 申请的code
+        ## content_type: 发送消息的类型，非必传，默认是text文本类型。目前支持"text","image","markdown","card_text","card_image".
+        ## msg_sender: app中展示的发送消息服务的名称， 非必传，如不传取 service_name
+        ## shop_id: 非必传，默认为None，根据自己的需求
+        ## user_id_list: 非必传，默认为空列表，根据自己的需求
+        ## nickname: 非必传，根据发送的消息类型content_type决定是否传递
+        ## title: 非必传，根据发送的消息类型content_type决定是否传递
+```
+## distributed_lock
+> add_lock (添加锁)
+> remove_lock (移除锁)
+```python
+    from sparrow_cloud.distributed_lock.lock_op import add_lock, remove_lock
+    #添加锁
+    res = add_lock("lock_key", 100)
+    if res.get("code") != 0:
+        #加锁失败
+    ##添加锁参数说明
+        ## key: 加锁的key值
+        ## exexpire_time: 必须是int型，表示超时时间。如果在超过这个时间没有调用移除锁，则会自动释放锁。所以该时间需要根据业务层处理时间尽可能准确
+        ## 返回字典结构为{"code":0/-1, "message":"xxxx"}或者{"message":"xxx"}
+        ## 如果没有code字段表示出错，需要查看message。
+        ## code为0表示加锁成功。其他数值表示加锁失败，停止执行之后的业务逻辑。
+        ## message表示具体的信息
+    # 移除锁
+    res = remove_lock("lock_key")
+    if res.get("code") != 0:
+        #移除锁失败
+    ##移除锁参数说明
+        ## key: 移除锁的key值
+        ## 返回字典结构为{"code":0/-1, "message":"xxxx"}或者{"message":"xxx"}
+        ## 如果没有code字段表示出错，需要查看message。
+        ## code为0表示移除锁成功。其他数值表示移除锁失败
+        ## message表示具体的信息，“1”表示移除成功，“0”表示没有该key值。
+```
+## Stargazers over time
+[![Stargazers over time](https://starchart.cc/hanguangbaihuo/sparrow_cloud.svg)](https://starchart.cc/hanguangbaihuo/sparrow_cloud)
+
+%package -n python3-sparrowcloud
+Summary:	基础Django和drf的微服务框架扩展
+Provides:	python-sparrowcloud
+BuildRequires:	python3-devel
+BuildRequires:	python3-setuptools
+BuildRequires:	python3-pip
+%description -n python3-sparrowcloud
+    # 调用方式
+    from sparrow_cloud.message_service.sender import send_task
+    # 非延时消息
+    data = send_task(exchange=exchange, 
+                        routing_key=routing_key, 
+                        message_code=message_code, 
+                        retry_times=3,
+                        *args,
+                        **kwargs)
+    # 延时消息
+    data = send_task(exchange=exchange, 
+                    routing_key=routing_key, 
+                    message_code=message_code, 
+                    retry_times=3,
+                    delay=True,
+                    delay_time=200
+                    *args,
+                    **kwargs)
+    # ps:
+    #     exchange: 交换机
+    #     routing_key: 路由
+    #     message_code: 消息码
+    #     retry_times: 重试次数，非必填，默认重试次数为3次（每次间隔1秒）
+    #     delay: 是否发送延时消息，默认为False，表示立即发送。如果设为True，则根据delay_time来设定延时时间
+    #     delay_time: 延时时间，单位为秒
+```
+## rabbitmq_consumer
+> 麻雀任务消费
+> 1. 获取队列 2. 消费任务
+``` python
+    QUEUE_CONF_1 = {
+        "QUEUE": "",
+        "TARGET_FUNC_MAP": {
+            "ORDER_PAY_SUC_ONLINE": "path",
+        },
+    }
+    # ps:
+    #     QUEUE_CONF_1  # 队列的配置
+    #         QUEUE  # 队列名称
+    #         TARGET_FUNC_MAP  # 队列消费的任务（字典中的键为message code，对应的值为执行该消息的任务函数路径字符串）
+    # 调用方式：
+    # 注册服务到 settings 下的 INSTALLED_APPS中
+    INSTALLED_APPS = [
+        "sparrow_cloud.apps.message_service",
+    ]
+    # 调用命令：
+    python3 manage.py rabbitmq_consumer --queue QUEUE_CONF_1
+    # ps：
+    # 参数说明
+    #     --queue ： 指定发送队列配置名称， 参照settings中QUEUE_CONF_1配置         
+```
+## table_api
+> 接受查询条件返回django model 序列化后的数据
+> 分为server端和client端
+``` python
+ # server 端配置
+    # settings注册服务
+    INSTALLED_APPS = [
+        "sparrow_cloud.apps.table_api",
+    ]
+    # url配置
+    urlpatterns = [
+        path('table/api/', include("sparrow_cloud.apps.table_api.urls")),
+    ]
+ # client端调用 
+    from sparrow_cloud.restclient import rest_client
+    service_address = "sparrow-demo:8000"
+    payload = {
+        "app_lable_model":"app_lable.model",
+        "filter_condition":{"product_id":"74101"}
+    }
+    response = rest_client.get(service_address, api_path='/table/api/', json=payload)
+    #  返回的数据结构：{'code': 0, 'message': 'ok', 'data': [{}]}
+    # ps:
+    #     app_lable_model: app_name.model(app_name:INSTALLED_APPS里面注册的服务的名字, model:app_lable下的model名字，不区分大小写)
+    #     filter_condition: 过滤数据， kwargs
+    #     server端使用orm filter查询数据，当前版本不支持order_by
+```
+## API SCHEMA REGISTER
+>描述：主动注册API 描述到文档服务 配置schema_command 需要的参数
+``` python
+    # settings 配置:
+        # 注册服务到 settings 下的 INSTALLED_APPS中
+        INSTALLED_APPS = [
+            "sparrow_cloud.apps.schema_command",
+        ]
+        # 本服务配置
+        SERVICE_CONF = {
+            "NAME": "",  # 本服务的名称
+            "SECRET": ""
+        }
+    # 调用方式:
+        python3 manage.py register_api_schema
+    # 使用说明:
+    #     1、view支持@api_view注解方式，view_class支持GenericApiView，GenericViewSet及其子类
+    #     2、接口描述书写在view函数或者view_class的__doc__上，建议使用markdown格式，展示更美观
+```
+>接口描述代码示例
+```python
+from rest_framework.decorators import api_view
+from rest_framework.generics import  RetrieveUpdateDestroyAPIView
+from rest_framework import  generics
+from rest_framework.viewsets import ModelViewSet
+@api_view(('GET',))
+def get_user(request):
+    """
+    ### 获取用户信息 ####
+        请求参数 id, 用户id
+        返回
+            {
+                "user_id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+            }
+    """
+class UserApiView(RetrieveUpdateDestroyAPIView, generics.GenericAPIView):
+    """
+    get:
+        ### 查询用户信息 ###
+        请求参数 id, 用户id
+        返回
+            {
+                "id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+            }
+    delete:
+        ### 删除用户 ###
+        路径参数
+            id 用户id
+        返回
+            404 用户id不存在
+            204 删除成功
+    """
+    def put(self, request, *args, **kwargs):
+        """
+        ### 覆盖修改用户 ###
+            请求参数
+                {
+                 "id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+                }
+            返回 200 修改成功
+        """
+        return super(UserApiView, self).put(self, request, *args, **kwargs)
+class CarViewSet(ModelViewSet):
+    """
+    list: 分页查询车辆
+    retrieve:获取车辆信息
+    update: 覆盖修改车辆
+    partial_update: 部分修改车辆
+    create: 创建车辆
+    destroy: 删除车辆
+    """
+```
+## DING_TALK
+> ding_talk client SDK (将消息发送到钉钉群或微信群)
+```python
+    # 使用:
+    from sparrow_cloud.dingtalk.sender import send_message
+    from sparrow_cloud.authorization.token import get_app_token
+    app_token = get_app_token()
+    send_message(msg="test", code_list=["test", "test1"], channel="dingtalk", message_type="text", token=app_token)
+    # 成功返回： {'code': 0, 'message': 'success'}
+    # 错误返回： HTTPException
+    # 参数说明：
+    # msg:消息内容
+    # code_list: 消息群code
+    # channel: 消息发送的渠道("wechat", "dingtalk"), 默认 dingtalk
+    # message_type:微信支持("text", "markdown")消息类型, 默认 text, 钉钉只支持text类型
+```
+## ExceptionMiddleware
+> 中间件 (捕获程序异常，并发送消息到飞书)
+``` python
+    # settings 配置
+    MIDDLEWARE = [                 
+        "sparrow_cloud.middleware.exception.ExceptionMiddleware"  
+    ]
+```
+## LogMiddleware
+> 日志中间件（将istio-proxy层的request_id放入线程中，并透传到业务逻辑层，可通过 request.id 获取，与链路追踪中的request_id 一致）
+> 此中间件需要配合log_filter 使用，才能在每条业务逻辑日志中插入request_id, 如单独使用只能透request_id
+``` python
+    # settings 配置
+    MIDDLEWARE = [                 
+        "sparrow_cloud.middleware.log_middleware.RequestIDMiddleware"
+    ]
+```
+## log_filter
+> log_filter(自定义logfilter,从线程中获取request_id，从每条日志中打印出来)
+> 需要与LogMiddleware 中间件配合使用，否则不生效
+``` python 
+# log_settings 配置
+LOGGING = {
+    'version': 1,
+    'disable_existing_loggers': False,
+    'filters': {
+        # 新增的配置
+        'request_id': {
+            '()': 'sparrow_cloud.filter.log_filters.RequestIDFilter'
+        }
+    },
+    'handlers': {
+        'console': {
+            'level': 'DEBUG',
+            'class': 'logging.StreamHandler',
+            'formatter': 'standard',   # 需要修改的的配置
+            'filters': ['request_id'], # 增加的 log_filter 的配置
+        },
+        # 以访问控制服务的日志举例子
+        'access_control': {
+            'class': 'logging.handlers.RotatingFileHandler',
+            'filters': ['request_id'], # 增加的配置
+            'level': 'DEBUG',
+            'formatter': 'standard', # 修改为新增的formatters 配置
+            'filename': os.path.join(os.path.sep, BASE_DIR_LOG, 'access_control.log'),
+            'mode': 'a',
+            'maxBytes': 1024 * 1024 * 5,
+            'backupCount': 1, # 修改
+        },
+    },
+    'formatters': {
+        # 增加的配置
+        'standard': {
+                    'format': '%(levelname)s %(asctime)s %(request_id)s %(lineno)d %(name)s %(module)s %(funcName)s %(process)d %(thread)d %(message)s'
+                },
+    },
+    # sparrow_cloud 的日志
+    'sparrow_cloud': {
+        'handlers': ['console', 'sparrow_cloud'],
+        'level': 'DEBUG',
+        'propagate': False,
+    },
+    'access_control': {
+        'handlers': ['console', 'access_control'],
+        'level': 'DEBUG',
+        'propagate': False,
+    }
+}
+}
+```
+## ACCESS_CONTROL_VERIFY
+> access_control_verify decorators (访问控制验证)
+``` python
+    # settings 配置
+    SERVICE_CONF = {
+        "NAME": "",  # value为本服务的注册名称
+        "SECRET": "",
+    }
+    # 访问控制client端settings配置
+    # SC_SKIP_ACCESS_CONTROL:  是否跳过访问控制，  True：跳过， false：不跳过
+    # 使用方式
+    # 函数视图使用方式示例
+    from sparrow_cloud.access_control.decorators import access_control_fbv
+    @api_view(('POST', 'GET', 'PUT', 'DELETE'))
+    @access_control_fbv("permission_example1")  # 位置放到最下层
+    def test(request, *args, **kwargs):
+        return Response({"message": "ok"}, status=status.HTTP_200_OK)
+    # 类视图使用方式(全部方法都验证)
+    from sparrow_cloud.access_control.decorators import access_control_cbv_all
+    @access_control_cbv_all("permission_example1")
+    class ProductOperationList(generics.ListCreateAPIView):
+        """请求方法：GET/POST"""
+        pass
+    # 类视图使用方式(根据method验证)
+    from sparrow_cloud.access_control.decorators import access_control_cbv_method
+    RESOURCE = {
+    "post": "permission_example1", 
+    "get": "permission_example2"
+    }
+    @access_control_cbv_method(RESOURCE)
+    class ProductOperationList(generics.ListCreateAPIView):
+        """请求方法：GET/POST"""
+        pass
+```
+## get_user_token
+> get_user_token (获取用户token)
+```python
+    # 获取用户token
+    from sparrow_cloud.authorization.token import get_user_token
+    user_token = get_user_token(user_id="21424kvjbcdjslafds")
+```
+## get_app_token
+> get_app_token (获取服务token)
+```python
+    # 获取app token
+    from sparrow_cloud.authorization.token import get_app_token
+    app_token = get_app_token()
+```
+## app_message
+> app_message (发送消息到揽月app, 服务端未开源)
+```python
+    #目前支持的消息类型有：纯文本、图片，Markdown、文字card和图片card
+    # 发送图片消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "http://www.test.com/image.png"
+    res = send_message(msg_data=msg_data, code_type="test", content_type="image", msg_sender="麻雀", shop_id="2")
+    # 发送文本消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "文本消息"
+    res = send_message(msg_data=msg_data, code_type="test", nickname="文本消息携带字段")
+    # 发送文本card消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "卡片消息内容"
+    res = send_message(msg_data=msg_data, code_type="test", content_type="card_text", title="通知")
+    ##  参数说明
+        ## msg_data: 消息主体。填充待发送的消息格式msg中的data数据
+        ## code_type: 申请的code
+        ## content_type: 发送消息的类型，非必传，默认是text文本类型。目前支持"text","image","markdown","card_text","card_image".
+        ## msg_sender: app中展示的发送消息服务的名称， 非必传，如不传取 service_name
+        ## shop_id: 非必传，默认为None，根据自己的需求
+        ## user_id_list: 非必传，默认为空列表，根据自己的需求
+        ## nickname: 非必传，根据发送的消息类型content_type决定是否传递
+        ## title: 非必传，根据发送的消息类型content_type决定是否传递
+```
+## distributed_lock
+> add_lock (添加锁)
+> remove_lock (移除锁)
+```python
+    from sparrow_cloud.distributed_lock.lock_op import add_lock, remove_lock
+    #添加锁
+    res = add_lock("lock_key", 100)
+    if res.get("code") != 0:
+        #加锁失败
+    ##添加锁参数说明
+        ## key: 加锁的key值
+        ## exexpire_time: 必须是int型，表示超时时间。如果在超过这个时间没有调用移除锁，则会自动释放锁。所以该时间需要根据业务层处理时间尽可能准确
+        ## 返回字典结构为{"code":0/-1, "message":"xxxx"}或者{"message":"xxx"}
+        ## 如果没有code字段表示出错，需要查看message。
+        ## code为0表示加锁成功。其他数值表示加锁失败，停止执行之后的业务逻辑。
+        ## message表示具体的信息
+    # 移除锁
+    res = remove_lock("lock_key")
+    if res.get("code") != 0:
+        #移除锁失败
+    ##移除锁参数说明
+        ## key: 移除锁的key值
+        ## 返回字典结构为{"code":0/-1, "message":"xxxx"}或者{"message":"xxx"}
+        ## 如果没有code字段表示出错，需要查看message。
+        ## code为0表示移除锁成功。其他数值表示移除锁失败
+        ## message表示具体的信息，“1”表示移除成功，“0”表示没有该key值。
+```
+## Stargazers over time
+[![Stargazers over time](https://starchart.cc/hanguangbaihuo/sparrow_cloud.svg)](https://starchart.cc/hanguangbaihuo/sparrow_cloud)
+
+%package help
+Summary:	Development documents and examples for sparrowcloud
+Provides:	python3-sparrowcloud-doc
+%description help
+    # 调用方式
+    from sparrow_cloud.message_service.sender import send_task
+    # 非延时消息
+    data = send_task(exchange=exchange, 
+                        routing_key=routing_key, 
+                        message_code=message_code, 
+                        retry_times=3,
+                        *args,
+                        **kwargs)
+    # 延时消息
+    data = send_task(exchange=exchange, 
+                    routing_key=routing_key, 
+                    message_code=message_code, 
+                    retry_times=3,
+                    delay=True,
+                    delay_time=200
+                    *args,
+                    **kwargs)
+    # ps:
+    #     exchange: 交换机
+    #     routing_key: 路由
+    #     message_code: 消息码
+    #     retry_times: 重试次数，非必填，默认重试次数为3次（每次间隔1秒）
+    #     delay: 是否发送延时消息，默认为False，表示立即发送。如果设为True，则根据delay_time来设定延时时间
+    #     delay_time: 延时时间，单位为秒
+```
+## rabbitmq_consumer
+> 麻雀任务消费
+> 1. 获取队列 2. 消费任务
+``` python
+    QUEUE_CONF_1 = {
+        "QUEUE": "",
+        "TARGET_FUNC_MAP": {
+            "ORDER_PAY_SUC_ONLINE": "path",
+        },
+    }
+    # ps:
+    #     QUEUE_CONF_1  # 队列的配置
+    #         QUEUE  # 队列名称
+    #         TARGET_FUNC_MAP  # 队列消费的任务（字典中的键为message code，对应的值为执行该消息的任务函数路径字符串）
+    # 调用方式：
+    # 注册服务到 settings 下的 INSTALLED_APPS中
+    INSTALLED_APPS = [
+        "sparrow_cloud.apps.message_service",
+    ]
+    # 调用命令：
+    python3 manage.py rabbitmq_consumer --queue QUEUE_CONF_1
+    # ps：
+    # 参数说明
+    #     --queue ： 指定发送队列配置名称， 参照settings中QUEUE_CONF_1配置         
+```
+## table_api
+> 接受查询条件返回django model 序列化后的数据
+> 分为server端和client端
+``` python
+ # server 端配置
+    # settings注册服务
+    INSTALLED_APPS = [
+        "sparrow_cloud.apps.table_api",
+    ]
+    # url配置
+    urlpatterns = [
+        path('table/api/', include("sparrow_cloud.apps.table_api.urls")),
+    ]
+ # client端调用 
+    from sparrow_cloud.restclient import rest_client
+    service_address = "sparrow-demo:8000"
+    payload = {
+        "app_lable_model":"app_lable.model",
+        "filter_condition":{"product_id":"74101"}
+    }
+    response = rest_client.get(service_address, api_path='/table/api/', json=payload)
+    #  返回的数据结构：{'code': 0, 'message': 'ok', 'data': [{}]}
+    # ps:
+    #     app_lable_model: app_name.model(app_name:INSTALLED_APPS里面注册的服务的名字, model:app_lable下的model名字，不区分大小写)
+    #     filter_condition: 过滤数据， kwargs
+    #     server端使用orm filter查询数据，当前版本不支持order_by
+```
+## API SCHEMA REGISTER
+>描述：主动注册API 描述到文档服务 配置schema_command 需要的参数
+``` python
+    # settings 配置:
+        # 注册服务到 settings 下的 INSTALLED_APPS中
+        INSTALLED_APPS = [
+            "sparrow_cloud.apps.schema_command",
+        ]
+        # 本服务配置
+        SERVICE_CONF = {
+            "NAME": "",  # 本服务的名称
+            "SECRET": ""
+        }
+    # 调用方式:
+        python3 manage.py register_api_schema
+    # 使用说明:
+    #     1、view支持@api_view注解方式，view_class支持GenericApiView，GenericViewSet及其子类
+    #     2、接口描述书写在view函数或者view_class的__doc__上，建议使用markdown格式，展示更美观
+```
+>接口描述代码示例
+```python
+from rest_framework.decorators import api_view
+from rest_framework.generics import  RetrieveUpdateDestroyAPIView
+from rest_framework import  generics
+from rest_framework.viewsets import ModelViewSet
+@api_view(('GET',))
+def get_user(request):
+    """
+    ### 获取用户信息 ####
+        请求参数 id, 用户id
+        返回
+            {
+                "user_id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+            }
+    """
+class UserApiView(RetrieveUpdateDestroyAPIView, generics.GenericAPIView):
+    """
+    get:
+        ### 查询用户信息 ###
+        请求参数 id, 用户id
+        返回
+            {
+                "id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+            }
+    delete:
+        ### 删除用户 ###
+        路径参数
+            id 用户id
+        返回
+            404 用户id不存在
+            204 删除成功
+    """
+    def put(self, request, *args, **kwargs):
+        """
+        ### 覆盖修改用户 ###
+            请求参数
+                {
+                 "id":"1",  # 用户ID
+                "user_name":"Tom" # 用户名称
+                }
+            返回 200 修改成功
+        """
+        return super(UserApiView, self).put(self, request, *args, **kwargs)
+class CarViewSet(ModelViewSet):
+    """
+    list: 分页查询车辆
+    retrieve:获取车辆信息
+    update: 覆盖修改车辆
+    partial_update: 部分修改车辆
+    create: 创建车辆
+    destroy: 删除车辆
+    """
+```
+## DING_TALK
+> ding_talk client SDK (将消息发送到钉钉群或微信群)
+```python
+    # 使用:
+    from sparrow_cloud.dingtalk.sender import send_message
+    from sparrow_cloud.authorization.token import get_app_token
+    app_token = get_app_token()
+    send_message(msg="test", code_list=["test", "test1"], channel="dingtalk", message_type="text", token=app_token)
+    # 成功返回： {'code': 0, 'message': 'success'}
+    # 错误返回： HTTPException
+    # 参数说明：
+    # msg:消息内容
+    # code_list: 消息群code
+    # channel: 消息发送的渠道("wechat", "dingtalk"), 默认 dingtalk
+    # message_type:微信支持("text", "markdown")消息类型, 默认 text, 钉钉只支持text类型
+```
+## ExceptionMiddleware
+> 中间件 (捕获程序异常，并发送消息到飞书)
+``` python
+    # settings 配置
+    MIDDLEWARE = [                 
+        "sparrow_cloud.middleware.exception.ExceptionMiddleware"  
+    ]
+```
+## LogMiddleware
+> 日志中间件（将istio-proxy层的request_id放入线程中，并透传到业务逻辑层，可通过 request.id 获取，与链路追踪中的request_id 一致）
+> 此中间件需要配合log_filter 使用，才能在每条业务逻辑日志中插入request_id, 如单独使用只能透request_id
+``` python
+    # settings 配置
+    MIDDLEWARE = [                 
+        "sparrow_cloud.middleware.log_middleware.RequestIDMiddleware"
+    ]
+```
+## log_filter
+> log_filter(自定义logfilter,从线程中获取request_id，从每条日志中打印出来)
+> 需要与LogMiddleware 中间件配合使用，否则不生效
+``` python 
+# log_settings 配置
+LOGGING = {
+    'version': 1,
+    'disable_existing_loggers': False,
+    'filters': {
+        # 新增的配置
+        'request_id': {
+            '()': 'sparrow_cloud.filter.log_filters.RequestIDFilter'
+        }
+    },
+    'handlers': {
+        'console': {
+            'level': 'DEBUG',
+            'class': 'logging.StreamHandler',
+            'formatter': 'standard',   # 需要修改的的配置
+            'filters': ['request_id'], # 增加的 log_filter 的配置
+        },
+        # 以访问控制服务的日志举例子
+        'access_control': {
+            'class': 'logging.handlers.RotatingFileHandler',
+            'filters': ['request_id'], # 增加的配置
+            'level': 'DEBUG',
+            'formatter': 'standard', # 修改为新增的formatters 配置
+            'filename': os.path.join(os.path.sep, BASE_DIR_LOG, 'access_control.log'),
+            'mode': 'a',
+            'maxBytes': 1024 * 1024 * 5,
+            'backupCount': 1, # 修改
+        },
+    },
+    'formatters': {
+        # 增加的配置
+        'standard': {
+                    'format': '%(levelname)s %(asctime)s %(request_id)s %(lineno)d %(name)s %(module)s %(funcName)s %(process)d %(thread)d %(message)s'
+                },
+    },
+    # sparrow_cloud 的日志
+    'sparrow_cloud': {
+        'handlers': ['console', 'sparrow_cloud'],
+        'level': 'DEBUG',
+        'propagate': False,
+    },
+    'access_control': {
+        'handlers': ['console', 'access_control'],
+        'level': 'DEBUG',
+        'propagate': False,
+    }
+}
+}
+```
+## ACCESS_CONTROL_VERIFY
+> access_control_verify decorators (访问控制验证)
+``` python
+    # settings 配置
+    SERVICE_CONF = {
+        "NAME": "",  # value为本服务的注册名称
+        "SECRET": "",
+    }
+    # 访问控制client端settings配置
+    # SC_SKIP_ACCESS_CONTROL:  是否跳过访问控制，  True：跳过， false：不跳过
+    # 使用方式
+    # 函数视图使用方式示例
+    from sparrow_cloud.access_control.decorators import access_control_fbv
+    @api_view(('POST', 'GET', 'PUT', 'DELETE'))
+    @access_control_fbv("permission_example1")  # 位置放到最下层
+    def test(request, *args, **kwargs):
+        return Response({"message": "ok"}, status=status.HTTP_200_OK)
+    # 类视图使用方式(全部方法都验证)
+    from sparrow_cloud.access_control.decorators import access_control_cbv_all
+    @access_control_cbv_all("permission_example1")
+    class ProductOperationList(generics.ListCreateAPIView):
+        """请求方法：GET/POST"""
+        pass
+    # 类视图使用方式(根据method验证)
+    from sparrow_cloud.access_control.decorators import access_control_cbv_method
+    RESOURCE = {
+    "post": "permission_example1", 
+    "get": "permission_example2"
+    }
+    @access_control_cbv_method(RESOURCE)
+    class ProductOperationList(generics.ListCreateAPIView):
+        """请求方法：GET/POST"""
+        pass
+```
+## get_user_token
+> get_user_token (获取用户token)
+```python
+    # 获取用户token
+    from sparrow_cloud.authorization.token import get_user_token
+    user_token = get_user_token(user_id="21424kvjbcdjslafds")
+```
+## get_app_token
+> get_app_token (获取服务token)
+```python
+    # 获取app token
+    from sparrow_cloud.authorization.token import get_app_token
+    app_token = get_app_token()
+```
+## app_message
+> app_message (发送消息到揽月app, 服务端未开源)
+```python
+    #目前支持的消息类型有：纯文本、图片，Markdown、文字card和图片card
+    # 发送图片消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "http://www.test.com/image.png"
+    res = send_message(msg_data=msg_data, code_type="test", content_type="image", msg_sender="麻雀", shop_id="2")
+    # 发送文本消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "文本消息"
+    res = send_message(msg_data=msg_data, code_type="test", nickname="文本消息携带字段")
+    # 发送文本card消息到app
+    from sparrow_cloud.app_message.sender import send_message
+    msg_data = "卡片消息内容"
+    res = send_message(msg_data=msg_data, code_type="test", content_type="card_text", title="通知")
+    ##  参数说明
+        ## msg_data: 消息主体。填充待发送的消息格式msg中的data数据
+        ## code_type: 申请的code
+        ## content_type: 发送消息的类型，非必传，默认是text文本类型。目前支持"text","image","markdown","card_text","card_image".
+        ## msg_sender: app中展示的发送消息服务的名称， 非必传，如不传取 service_name
+        ## shop_id: 非必传，默认为None，根据自己的需求
+        ## user_id_list: 非必传，默认为空列表，根据自己的需求
+        ## nickname: 非必传，根据发送的消息类型content_type决定是否传递
+        ## title: 非必传，根据发送的消息类型content_type决定是否传递
+```
+## distributed_lock
+> add_lock (添加锁)
+> remove_lock (移除锁)
+```python
+    from sparrow_cloud.distributed_lock.lock_op import add_lock, remove_lock
+    #添加锁
+    res = add_lock("lock_key", 100)
+    if res.get("code") != 0:
+        #加锁失败
+    ##添加锁参数说明
+        ## key: 加锁的key值
+        ## exexpire_time: 必须是int型，表示超时时间。如果在超过这个时间没有调用移除锁，则会自动释放锁。所以该时间需要根据业务层处理时间尽可能准确
+        ## 返回字典结构为{"code":0/-1, "message":"xxxx"}或者{"message":"xxx"}
+        ## 如果没有code字段表示出错，需要查看message。
+        ## code为0表示加锁成功。其他数值表示加锁失败，停止执行之后的业务逻辑。
+        ## message表示具体的信息
+    # 移除锁
+    res = remove_lock("lock_key")
+    if res.get("code") != 0:
+        #移除锁失败
+    ##移除锁参数说明
+        ## key: 移除锁的key值
+        ## 返回字典结构为{"code":0/-1, "message":"xxxx"}或者{"message":"xxx"}
+        ## 如果没有code字段表示出错，需要查看message。
+        ## code为0表示移除锁成功。其他数值表示移除锁失败
+        ## message表示具体的信息，“1”表示移除成功，“0”表示没有该key值。
+```
+## Stargazers over time
+[![Stargazers over time](https://starchart.cc/hanguangbaihuo/sparrow_cloud.svg)](https://starchart.cc/hanguangbaihuo/sparrow_cloud)
+
+%prep
+%autosetup -n sparrowcloud-4.1.1
+
+%build
+%py3_build
+
+%install
+%py3_install
+install -d -m755 %{buildroot}/%{_pkgdocdir}
+if [ -d doc ]; then cp -arf doc %{buildroot}/%{_pkgdocdir}; fi
+if [ -d docs ]; then cp -arf docs %{buildroot}/%{_pkgdocdir}; fi
+if [ -d example ]; then cp -arf example %{buildroot}/%{_pkgdocdir}; fi
+if [ -d examples ]; then cp -arf examples %{buildroot}/%{_pkgdocdir}; fi
+pushd %{buildroot}
+if [ -d usr/lib ]; then
+	find usr/lib -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/lib64 ]; then
+	find usr/lib64 -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/bin ]; then
+	find usr/bin -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+if [ -d usr/sbin ]; then
+	find usr/sbin -type f -printf "/%h/%f\n" >> filelist.lst
+fi
+touch doclist.lst
+if [ -d usr/share/man ]; then
+	find usr/share/man -type f -printf "/%h/%f.gz\n" >> doclist.lst
+fi
+popd
+mv %{buildroot}/filelist.lst .
+mv %{buildroot}/doclist.lst .
+
+%files -n python3-sparrowcloud -f filelist.lst
+%dir %{python3_sitelib}/*
+
+%files help -f doclist.lst
+%{_docdir}/*
+
+%changelog
+* Mon May 15 2023 Python_Bot <Python_Bot@openeuler.org> - 4.1.1-1
+- Package Spec generated
diff --git a/sources b/sources
new file mode 100644
index 0000000..eabf591
--- /dev/null
+++ b/sources
@@ -0,0 +1 @@
+5aff9745023ddccc113dbb6fdf0d2a30  sparrowcloud-4.1.1.tar.gz