有了@StreamListener conditions,我们可以在每种消息类型下选择如何处理该消息。例如:Also, for SpEL, the root object of the evaluation context is Message so you can do evaluationon individual headers (or message) as well ….routing-expression=headers['type']
是否可以将路由表
我需要使用tweepy流侦听器迭代tweet,可能每5-10个tweet对其进行批处理,将其存储在一个数组中,并使用tweet数组执行一些逻辑。查找有关如何在streamlistener类下使用on_data对象对它们进行批处理的帮助。class stdoutlistener(StreamListener): data = json.loads(data)(如贡献者、文本、id、源等),但不迭代tweet本身。如何用on_data