LeeC20

接受非booster传过来的消息，没有extra， 导致consume 失败

1

版本41.2 脚本：basic_consumer.py line： 512 我改成下面这样 就能运行 # noinspection PyProtectedMember def _run(self, kw: dict, ): try: t_start_run_fun = time.time() max_retry_times = self._get_priority_conf(kw, 'max_retry_times') current_function_result_status = FunctionResultStatus(self.queue_name, self.consuming_function.__name__, kw['body'], ) current_retry_times =...