Skip to main content

发布订阅注解方式

Project description

  • 在方法上添加@task就可以直接开启一个线程执行任务
  • 常用参数:
    • 生产者: role="producer",topic="自定义"
    • 消费者: role="consumer",subscribe="自定义",publish_after="自定义"
  • 说明:
    • role: 用于区分上下游 producer/consumer
    • topic: 发布的主题
    • subscribe: 对哪些主题感兴趣
    • publish_after: 消费完后继续发布新主题
  • 特别的:方法的返回值可以进行传递,若没有返回值则不会发布新主题

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

dotask-0.1.0.tar.gz (8.3 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

dotask-0.1.0-py3-none-any.whl (8.8 kB view details)

Uploaded Python 3

File details

Details for the file dotask-0.1.0.tar.gz.

File metadata

  • Download URL: dotask-0.1.0.tar.gz
  • Upload date:
  • Size: 8.3 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.2

File hashes

Hashes for dotask-0.1.0.tar.gz
Algorithm Hash digest
SHA256 d33c9ce5461a71ea29d0e450e586a219e998f18532e833eea2139f69f1cf0f66
MD5 d0535d53d179b6aa39b5dd98ef3ff20f
BLAKE2b-256 ad122af3f797ecba3398e2789ee3aa4ae8c6bdd4c1e73f7e0903b69b79a53f41

See more details on using hashes here.

File details

Details for the file dotask-0.1.0-py3-none-any.whl.

File metadata

  • Download URL: dotask-0.1.0-py3-none-any.whl
  • Upload date:
  • Size: 8.8 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.14.2

File hashes

Hashes for dotask-0.1.0-py3-none-any.whl
Algorithm Hash digest
SHA256 35f8c25ddf34e2ad34f31423962fa130baa02052567dfe96047b1f9db4175f5d
MD5 58ba1150915bc84ee410c7c03c48795c
BLAKE2b-256 fdfa2011d9b65965855c9722f84edb4722c30043d4a4a7ef5953391aa315fcb7

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page