python - 我想要一个像redis pubsub中的kafka client_id这样的功能

In lại 作者：可可西里 更新时间：2023-11-01 11:23:07 25 4

r = redis.StrictRedis(host=host, port=port, db=0)
channel = r.pubsub()

for i in range(10):
    print(r.publish("test", i))

print('end')

r = redis.StrictRedis(host=host, port=port, db=0)

p = r.pubsub()
p.subscribe('test')

# while True:
# message = p.get_message()
# if message:
# print("Subscriber: %s" % message['data'])

for z in p.listen():
    print(z)

r = redis.StrictRedis(host=host, port=port, db=0)

p = r.pubsub()
p.subscribe('test')

# while True:
# message = p.get_message()
# if message:
# print("Subscriber: %s" % message['data'])

for z in p.listen():
    print(z)

{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'0'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'1'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'2'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'3'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'4'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'5'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'6'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'7'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'8'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'9'}

{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'0'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'1'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'2'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'3'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'4'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'5'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'6'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'7'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'8'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'9'}

{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'0'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'2'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'4'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'6'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'8'}

{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'1'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'3'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'5'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'7'}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'9'}

25 4 0

• eclipse - 一旦在 eclipse RCP 中安装了新的插件/功能，是否有任何方法可以自动从磁盘中清除旧的插件/功能？

  我正在构建一个 RCP 应用程序，其中每个季度都会更新功能/插件。因此，如果用户选择自动更新功能/插件，则会下载更新插件的新 jar，但旧插件仍在使用我不再使用的磁盘空间。 我厌倦了删除包含旧 jar

• extjs - 如何从外部 Controller 功能(如sencha touch中的全局功能)调用 Controller 功能

  我如何从外部 Controller 功能中调用 Controller 内部的功能，例如电话间隙回调功能 这是 Controller 外部定义的功能 function onDeviceReady()

• dart - 检查( native )功能/类/功能(例如 MediaSource)是否可用/受支持

  如果某个功能(例如 MediaSource)可用，我如何使用 Google Dart 检查。 new MediaSource() 抛出一个错误。如何以编程方式检查此类或功能是否存在？有任何想法吗？是否

• azure - Orchestrator 功能 'XYZ' 失败 : The function 'XYZ' doesn't exist, 已禁用，或者不是 Orchestrator 功能

  我正在尝试运行 Azure Orchestrations，突然我开始从 statusQueryGetUri 收到错误: 协调器函数“UploadDocumentOrchestrator”失败:函数“U

• iphone - 在一个可执行文件中使用 iPhone OS 3.0 功能(如果可用)和 2.1 功能(如果不可用)

  我见过 iPhone 上的应用程序，如果在 3.0 上运行，将使用 3.0 功能/API，例如应用内电子邮件编辑器，如果在 2.x 上运行，则不使用这些功能，并退出应用程序以启动邮件相反。 这是怎么做

• 功能 "normalization"

  这是 DB 规范化理论中的一个概念: Third normal form is violated when a non-key field is a fact about another non-ke

• 正确的#if 功能

  如果我定义 #if SOMETHING #endif 而且我还没有在任何地方定义 SOMETHING。 #if 中的代码会编译吗？ 最佳答案 当#if的参数表达式中使用的名称未定义为宏时(在所有其他宏

• algorithm - A* 功能

  我刚刚澄清了 A* 路径查找应该如何在两条路径具有相等值的 [情况] 下运行，无论是在计算期间还是在结束时，如果有两条相等的短路径。 例如，我在我的起始节点，我可以扩展到两个可能的节点，但它们都具有相

• Java 功能

  Java有没有类似下面的东西 宏 一种遍历所有私有(private)字段的方法 类似于 smalltalk symbols 的东西——即用于快速比较静态字符串的东西？ 请注意，我正在尝试为 black

• c - "while()"功能？

  这个程序应该将华氏度转换为摄氏度: #include int main() { float fahrenheit, celsius; int max, min, step;

• LOTO示波器软件PC缓存(波形录制与回放)功能

    当打开PC缓存功能后, 软件将采用先进先出的原则排队对示波器采集的每一帧数据, 进行帧缓存。 当发现屏幕中有感兴趣的波形掠过时, 鼠标点击软件的(暂停)按钮, 可以选择回看某一帧的波形

• r - 自定义环境中的范围(功能)

  我有一个特殊的(虚拟)函数，我想在沙盒环境中使用它: disable.system.call eval(parse(text = 'model.frame("1 ~ 1")'), envir = e

• ServiceStack CORS 功能

  使用新的 Service 实现，我是否必须为我的所有服务提供一个 Options 方法？ 使用我的所有服务当前使用的旧 ServiceBase 方法，OPTIONS 返回 OK，但没有 Access-

• Clojure 线程!功能

  我正在阅读 Fogus 的关于 Clojure 的喜悦的书，在并行编程章节中，我看到了一个函数定义，它肯定想说明一些重要的事情，但我不知道是什么。此外，我看不到这个函数有什么用 - 当我执行时，它什么

• vim - 如何限制vim的%功能？

  我有大量的 C 代码，大部分代码被注释掉和/或 #if 0。当我使用 % 键匹配 if-else 的左括号和右括号时，它也匹配注释掉的代码。 有没有办法或vim插件在匹配括号时不考虑注释掉或#if 0

• SML map 功能

  我有这个功能: map(map(fn x =>[x])) [[],[1],[2,3,4]]; 产生: val it = [[],[[1]],[[2],[3],[4]]] 我不明白这个功能是如何工作的。

• Azure 功能 - 门户代码部署功能正在跳过构建

  我使用 Visual Studio 代码创建了一个函数应用程序，然后发布了它。功能应用程序运行良好。我现在在功能门户中使用代码部署功能(KUDU)并跳过构建。下面是日志 9:55:46 AM

• r - R如何根据现有数据创建列/功能

  我有一个数据框df: userID Score Task_Alpha Task_Beta Task_Charlie Task_Delta 3108 -8.00 Easy Easy

• r - 功能:将返回的数据框保存到工作区

  我真的无法解决这个问题: 我有一个返回数据框的函数。但是，数据框仅打印在我的控制台中，尽管我希望将其存储在工作空间中。我怎样才能做到这一点？ 样本数据: n <- 32640 t <- seq(3*p

• playframework - 类型安全激活器可用的命令行选项/功能

  有没有办法找出所有可能的激活器命令行选项？ activator -help仅提供最低限度的可用选项/功能列表，但所有好的东西都隐藏起来，即使在 typesafe 网站在线文档中也不可用。 到目前为止，