首页sysLogger.error('request exception %s' % e) if node: globalContext.runningManager.updateNodeStatus(node, NodeStatus.ABORT.name) globalContext.runningManager.updateNodeMessage(node, str(e)) globalContext.runningManager.updateJobStatus(self.job,JobStatus.ABORT.name) globalContext.runningManager.updateJobMessage(self.job,str('run atom ' + node_name + ' exception')) # jobAbortNotice = {'notice':'job','asset': self.job.asset, 'name': self.job.name, 'status': Status.ABORT.name} # noticeManager.send_notice(jobAbortNotice) jobAbortNotice = {'notice':'job','asset': self.job.asset, 'name': self.job.name, 'status': JobStatus.ABORT.name} globalContext.runningManager.send_runtime_notice(str(json.dumps(jobAbortNotice))) raise Exception('asset ' + self.job.asset + ' name ' + self.job.name + ' run node ' + node_name + ' exception %s' % e)

sysLogger.error('request exception %s' % e) if node: globalContext.runningManager.updateNodeStatus(node, NodeStatus.ABORT.name) globalContext.runningManager.updateNodeMessage(node, str(e)) globalContext.runningManager.updateJobStatus(self.job,JobStatus.ABORT.name) globalContext.runningManager.updateJobMessage(self.job,str('run atom ' + node_name + ' exception')) # jobAbortNotice = {'notice':'job','asset': self.job.asset, 'name': self.job.name, 'status': Status.ABORT.name} # noticeManager.send_notice(jobAbortNotice) jobAbortNotice = {'notice':'job','asset': self.job.asset, 'name': self.job.name, 'status': JobStatus.ABORT.name} globalContext.runningManager.send_runtime_notice(str(json.dumps(jobAbortNotice))) raise Exception('asset ' + self.job.asset + ' name ' + self.job.name + ' run node ' + node_name + ' exception %s' % e)

时间: 2024-04-19 15:24:11 浏览: 65

syslogger:将系统日志消息转发到Kafka

系统记录器 Syslogger是用于将Rsyslog消息转发到。是一个“高性能，分布式消息传递系统”，非常适合于业务和系统事件数据的整理。有关更多信息，请参阅Jay Kreps精彩的。 Syslogger将帮助您将syslog消息转发到Kafka。消息从转发通过TCP连接到syslogger。 Rsyslog已经有很多东西可以使转发消息尽可能可靠，处理背压以及将排队的消息写入磁盘等。有关更多信息，请参见。设计 Syslogger试图通过减轻Rsyslog的故障处理责任来成为Rsyslog的良好公民。通过向Kafka同步发送消息来实现可靠性（在仅使用TCP的情况下尽可能多）：如果在将消息转发到Kafka时出现问题或延迟，我们将对Rsyslog施加尽可能多的背压。默认情况下，Syslogger在端口1514上启动一个TCP侦听器。它还尝试连接到ZooKeeper，以检索

这段代码是一个异常处理的部分。当发生异常时，会将异常信息记录到日志中，并更新相关节点和作业的状态和消息。然后，通过发送运行时通知，将作业的中止状态通知给全局上下文。最后，抛出一个异常，包含作业资产、作业名称、运行节点和异常信息。请注意，我是一个AI助手，无法运行代码或提供完整的上下文。如果你有任何关于代码的具体问题，请提供更多的上下文信息。我将尽力帮助你。

阅读全文