Python fastapi-plugins包_程序模块 - PyPI

FastAPI框架插件

fastapi-plugins的Python项目详细描述

fastapi插件

FastAPI框架插件

缓存
- Memcached
- Redis
在
Scheduler
芹菜
MQ
测井
健康
普通

变更

见release notes

安装

默认情况下只包含Redis和Scheduler
memcached添加Memcached
all添加上面的所有内容

pip install fastapi-plugins
pip install fastapi-plugins[memcached]
pip install fastapi-plugins[all]

插件

缓存

内存缓存

有效变量为

MEMCACHED_HOST-Memcached服务器主机。在
MEMCACHED_PORT-Memcached服务器端口。默认值为11211。在
MEMCACHED_POOL_MINSIZE-要在池中创建的最小可用连接数。默认值为1。在
MEMCACHED_POOL_SIZE-池中要保持的最大连接数。默认值为10。必须大于0。None不允许。在
MEMCACHED_PRESTART_TRIES-号码尝试连接到Memcached实例。在
MEMCACHED_PRESTART_WAIT-应用程序启动时连接失败之间等待的间隔（秒）。在

示例

^{pr2}$

Redis

支持

单个实例
哨兵

有效变量为

REDIS_TYPE
- redis-单个Redis实例
- sentinel-Redis集群
在
REDIS_URL-连接到Redis服务器的URL。例子 redis://user:password@localhost:6379/2。支持协议redis://， rediss://（基于TLS的redis）和unix://。在
REDIS_HOST-Redis服务器主机。在
REDIS_PORT-Redis服务器端口。默认值为6379。在
REDIS_PASSWORD-服务器的Redis密码。在
REDIS_DB-Redis-db（从零开始的数字索引）。默认值是0。在
REDIS_CONNECTION_TIMEOUT-Redis连接超时。默认值是2。在
REDIS_POOL_MINSIZE-要在池中创建的最小可用连接数。默认值为1。在
REDIS_POOL_MAXSIZE-池中要保留的最大连接数。默认值为10。必须大于0。None不允许。在
REDIS_SENTINELS-列出Redis sentinel地址或元组。在
REDIS_SENTINEL_MASTER-哨兵配置中主服务器的名称。默认值是mymaster。在
REDIS_PRESTART_TRIES-号码尝试连接到a Redis实例。在
REDIS_PRESTART_WAIT-应用程序启动时连接失败之间等待的间隔（秒）。在

示例

# run with `uvicorn demo_app:app`importtypingimportaioredisimportfastapiimportpydanticimportfastapi_pluginsclassAppSettings(OtherSettings,fastapi_plugins.RedisSettings):api_name:str=str(__name__)app=fastapi.FastAPI()config=AppSettings()@app.get("/")asyncdefroot_get(cache:aioredis.Redis=fastapi.Depends(fastapi_plugins.depends_redis),)->typing.Dict:returndict(ping=awaitcache.ping())@app.on_event('startup')asyncdefon_startup()->None:awaitfastapi_plugins.redis_plugin.init_app(app,config=config)awaitfastapi_plugins.redis_plugin.init()@app.on_event('shutdown')asyncdefon_shutdown()->None:awaitfastapi_plugins.redis_plugin.terminate()

Docker Compose-Redis示例

version:'3.7'services:redis:image:redisports:-"6379:6379"demo_fastapi_plugin:image:demo_fastapi_pluginenvironment:-REDIS_TYPE=redis-REDIS_HOST=redis-REDIS_PORT=6379ports:-"8000:8000"

Docker Compose-Redis Sentinel示例

version:'3.7'services:...redis-sentinel:ports:-"26379:26379"environment:-...links:-redis-master-redis-slavedemo_fastapi_plugin:image:demo_fastapi_pluginenvironment:-REDIS_TYPE=sentinel-REDIS_SENTINELS=redis-sentinel:26379ports:-"8000:8000"

调度程序

简单地将awaitable作业安排为任务。在

long运行async函数（例如监视系统或事件的文件）
优雅地取消生成的任务

有效变量为：

AIOJOBS_CLOSE_TIMEOUT-取消任务前的超时（以秒为单位）。在
AIOJOBS_LIMIT-要执行的并发任务数。在
AIOJOBS_PENDING_LIMIT-挂起的作业数（等待fr执行）。在

# run with `uvicorn demo_app:app`import...importfastapi_pluginsclassAppSettings(OtherSettings,fastapi_plugins.RedisSettings,fastapi_plugins.SchedulerSettings):api_name:str=str(__name__)app=fastapi.FastAPI()config=AppSettings()@app.post("/jobs/schedule/<timeout>")asyncdefjob_post(timeout:int=fastapi.Query(...,title='the job sleep time'),cache:aioredis.Redis=fastapi.Depends(fastapi_plugins.depends_redis),scheduler:aiojobs.Scheduler=fastapi.Depends(fastapi_plugins.depends_scheduler),# @IgnorePep8)->str:asyncdefcoro(job_id,timeout,cache):awaitcache.set(job_id,'processing')try:awaitasyncio.sleep(timeout)iftimeout==8:raiseException('ugly error')exceptasyncio.CancelledError:awaitcache.set(job_id,'canceled')exceptException:awaitcache.set(job_id,'erred')else:awaitcache.set(job_id,'success')job_id=str(uuid.uuid4()).replace('-','')awaitcache.set(job_id,'pending')awaitscheduler.spawn(coro(job_id,timeout,cache))returnjob_id@app.get("/jobs/status/<job_id>")asyncdefjob_get(job_id:str=fastapi.Query(...,title='the job id'),cache:aioredis.Redis=fastapi.Depends(fastapi_plugins.depends_redis),)->typing.Dict:status=awaitcache.get(job_id)ifstatusisNone:raisefastapi.HTTPException(status_code=starlette.status.HTTP_404_NOT_FOUND,detail='Job %s not found'%job_id)returndict(job_id=job_id,status=status)@app.on_event('startup')asyncdefon_startup()->None:awaitfastapi_plugins.redis_plugin.init_app(app,config=config)awaitfastapi_plugins.redis_plugin.init()awaitfastapi_plugins.scheduler_plugin.init_app(app=app,config=config)awaitfastapi_plugins.scheduler_plugin.init()@app.on_event('shutdown')asyncdefon_shutdown()->None:awaitfastapi_plugins.scheduler_plugin.terminate()awaitfastapi_plugins.redis_plugin.terminate()

。。。更多正在进行中…

发展

欢迎通过Issues

许可证

这个项目是根据麻省理工学院的许可条款授权的。在

变更

0.6.0（2020年11月26日）

[feature]内存缓存

0.5.0（2020年11月25日）

{cd4>{a8>}（例如，^无）。在
[typo]修复自述文件（#7）中的拼写错误。在
[功能]添加Redis TTL（#8）。在

0.4.2（2020年11月24日）

[错误]修复Redis URL（#4）。在

0.4.1（2020-06-16）

重构要求

0.4.0（2020-04-09）

对extra的结构和拆分依赖关系

0.3.0（2020-04-07）

调度器：基于aiojobs的任务调度器

0.2.1（2020-04-06）

Redis：预启动

0.2.0（2019-12-11）

雷迪斯：哨兵

0.1.0（2019-2011年-20）

初始版本：简单redis池客户端

欢迎加入QQ群-->： 979659372

fastapi-plugins 0.6.0

fastapi-plugins的Python项目详细描述

fastapi插件

变更

安装

插件

缓存

内存缓存

示例

Redis

示例

Docker Compose-Redis示例

Docker Compose-Redis Sentinel示例 version:'3.7'services:...redis-sentinel:ports:-"26379:26379"environment:-...links:-redis-master-redis-slavedemo_fastapi_plugin:image:demo_fastapi_pluginenvironment:-REDIS_TYPE=sentinel-REDIS_SENTINELS=redis-sentinel:26379ports:-"8000:8000"

调度程序

。。。更多正在进行中…

发展

许可证

变更

0.6.0（2020年11月26日）

0.5.0（2020年11月25日）

0.4.2（2020年11月24日）

0.4.1（2020-06-16）

0.4.0（2020-04-09）

0.3.0（2020-04-07）

0.2.1（2020-04-06）

0.2.0（2019-12-11）

0.1.0（2019-2011年-20）

推荐PyPI第三方库

django-dynamicwidgets

github_timeline_rss

flask_json_multidict

micropython-xml.dom

dsin100daysv9

commondata.ee

dwdweather

spkcspider-domainauth

cryptology-ws-client

Products.ATBiblioStyles

django-lithium-api

reveal-graph-embedding

coko

Axilent-Dox

gluetool

导 航 栏

项目 链接

标 签

维护者

最新PyPI项目

最新Python常见问题

Docker Compose-Redis Sentinel示例
version:'3.7'services:...redis-sentinel:ports:-"26379:26379"environment:-...links:-redis-master-redis-slavedemo_fastapi_plugin:image:demo_fastapi_pluginenvironment:-REDIS_TYPE=sentinel-REDIS_SENTINELS=redis-sentinel:26379ports:-"8000:8000"

导航栏

项目链接

标签