下游任务订阅redis stream $ redis-cli > ob.limit b{btc_usdt} * 10000 buy 1 10000 88181047656742912 交易系统架构设计-计算K线 • 实现为Redis Module的流式聚合组件(https://github.com/cryptorelay/redis-aggregation) $ redis-cli > agg.new agg{btc_usdt} Kafka-like • 一个订阅者的情况，消息有序 • Consumer group负载均衡（不保证消息顺序） • 可以批量处理消息 • 在同一个事务中存储处理结果和更新消费offset $ redis-cli > xread block 60 count 100000 streams b{btc_usdt}o offset … 交易系统架构设计-异步任务 def read_events(redis

localhost:6379 on the client, # so that the remote 'redis-cli' program ends up speaking to the local # redis-server. with remote_tunnel(6379): run("redis-cli -i") The database might be installed on a client redis.internal:6379 on the client with remote_tunnel(6379, local_host="redis.internal") run("redis-cli -i") remote_tunnel accepts up to four arguments: remote_port (mandatory) is the remote port to

localhost:6379 on the client, # so that the remote 'redis-cli' program ends up speaking to the local # redis-server. with remote_tunnel(6379): run("redis-cli -i") The database might be installed on a client redis.internal:6379 on the client with remote_tunnel(6379, local_host="redis.internal") run("redis-cli -i") remote_tunnel accepts up to four arguments: remote_port (mandatory) is the remote port to

can monitor the Celery cluster using the redis-cli(1) command to list lengths of queues. Inspecting queues Finding the number of tasks in a queue: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER llen all available queues, invoke: 72 Chapter 2. User Guide Celery Documentation, Release 2.5.5 $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER keys \* Note: If a list has no elements in Redis, it doesn’t

redis: image: ${MS_IMAGE_PREFIX}/redis:6.2.6 container_name: redis healthcheck: test: ["CMD", "redis-cli", "ping"] interval: 6s timeout: 5s retries: 50 environment: TZ: "Asia/Shanghai" ports: -

can monitor the Celery cluster using the redis-cli(1) command to list lengths of queues. Inspecting queues Finding the number of tasks in a queue: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER llen llen QUEUE_NAME The default queue is named celery. To get all available queues, invoke: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER keys \* Note If a list has no elements in Redis, it doesn’t exist

using the redis-cli(1) command to list lengths of queues. Inspecting queues Finding the number of tasks in a queue: 2.3. User Guide 129 Celery Documentation, Release 3.1.25 $ redis-cli -h HOST -p DATABASE_NUMBER llen QUEUE_NAME The default queue is named celery. To get all available queues, invoke: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER keys \* Note: Queue keys only exists when there are tasks in

can monitor the Celery cluster using the redis-cli(1) command to list lengths of queues. Inspecting queues Finding the number of tasks in a queue: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER llen llen QUEUE_NAME The default queue is named celery. To get all available queues, invoke: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER keys \* Note Queue keys only exists when there are tasks in them,

can monitor the Celery cluster using the redis-cli(1) command to list lengths of queues. Inspecting queues Finding the number of tasks in a queue: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER llen llen QUEUE_NAME The default queue is named celery. To get all available queues, invoke: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER keys \* Note: Queue keys only exists when there are tasks in them,

can monitor the Celery cluster using the redis-cli(1) command to list lengths of queues. Inspecting queues Finding the number of tasks in a queue: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER llen llen QUEUE_NAME The default queue is named celery. To get all available queues, invoke: $ redis-cli -h HOST -p PORT -n DATABASE_NUMBER keys \* Note Queue keys only exists when there are tasks in them,