Skip to main content

simqsvr

SIMQ服务器。基于redis的消息队列,通过web接口提供对外服务。

安装

pip install simqsvr

接口列表

接口地址 接口名称
/simq/api/{channel}/rpush 添加消息(高优先级)
/simq/api/{channel}/lpush 添加消息(低优先级)
/simq/api/{channel}/dpush 添加延迟消息
/simq/api/{channel}/pop 获取消息执行
/simq/api/{channel}/ack 确认消息执行完成
/simq/api/{channel}/ret 退还消息
/simq/api/{channel}/query 查询消息详情
/simq/api/{channel}/cancel 取消消息(仅限待处理状态)
/simq/api/{channel}/delete 删除消息

配置项

  • SIMQ_MQ_DEFAULT: 默认为default,即django-redis标准添加的CACHES实例名称。
  • SIMQ_MQS: 允许按channel使用不同caches实例。
  • SIMQ_ACK_EVENT_EXPIRE: 消息处理完成通知过期时间。默认为10分钟。
  • SIMQ_DONE_ITEM_EXPIRE: 已处理消息和结果的保存时间。默认为7天。
  • SIMQ_APIKEYS: apikey认证密钥。不设置密钥则表示无需认证。
  • SIMQ_APIKEY_HEADER: apikey认证请求头名称。默认为apikey。

简易使用方法

# 创建数据库
manage-simqsvr migrate
# 创建超级用户
manage-simqsvr createsuperuser

# 启动服务
manage-simqsvr runserver 0.0.0.0:80 --noreload
  • 创建数据库&创建超级用户,只是用来登录swagger接口管理界面。
  • 如果不需要使用swagger接口管理功能,可以忽略上述两个步骤。

注意事项

  • simqsvr目前仅支持基于redis的消息队列。
  • 必须要按django-redis标准来配置CACHES配置项。如:
    # decode_responses=True是必须的
    CACHES = {
        "default": {
            "BACKEND": "django_redis.cache.RedisCache",
            "LOCATION": "redis://127.0.0.1:6379/0?decode_responses=True",
        }
    }
    

版本

0.1.0

  • 版本首发。

0.1.3

  • 完善容器打包支持。
  • 修正swagger默认apikey认证header问题。

Release files for simqsvr 0.1.3

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for simqsvr 0.1.3
File Size Uploaded
simqsvr-0.1.3.tar.gz 14.6 kB Details

Built distribution (wheel)

Table of built distributions (wheels) for simqsvr 0.1.3
File Interpreter ABI Platform
simqsvr-0.1.3-py3-none-any.whl Python 3 none any Details

Total release size: 30.2 kB

Release files / simqsvr-0.1.3.tar.gz

Download URL simqsvr-0.1.3.tar.gz
Size 14.6 kB
Tags Source
SHA-256 checksum
How to use checksums
7308cc5e7d6f99ceef7628b3a1171c3240c19942f7e526e3ed97a33cc67eb80f
BLAKE2b-256 checksum
How to use checksums
a7b0ad1ebb2c6068ec4c1268317918088b2371875a73bdc532dee2466f8a1a68
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/5.1.1 CPython/3.11.9

Release files / simqsvr-0.1.3-py3-none-any.whl

Download URL simqsvr-0.1.3-py3-none-any.whl
Size 15.6 kB
Tags Python 3
SHA-256 checksum
How to use checksums
690221ad3965cf004228bc39c5ea247b663c6f1f568bd44ceeb3e5593cda4675
BLAKE2b-256 checksum
How to use checksums
714ad848fdf2e19c966d4598506347199122aea7d2b5372381ad79093ffcdc33
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/5.1.1 CPython/3.11.9

Release history Release notifications | RSS feed

This release

0.1.3 This release

2 release files

0.1.2

2 release files

0.1.1

2 release files

0.1.0

2 release files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page