rejected 3.20.4

功能

• 自动异常处理，包括连接管理和使用者重新启动
• 能够根据消息头自动解码和反序列化消息体的智能使用者类
• 指标记录和提交给statsd和influxdb
• 内置的用户代码分析
• 能够在使用者中编写异步代码，允许与外部资源进行并行通信

文档

https://rejected.readthedocs.io

示例消费者

fromrejectedimportconsumerimportloggingLOGGER=logging.getLogger(__name__)classTest(consumer.Consumer):defprocess(self,message):LOGGER.debug('In Test.process: %s'%message.body)

importloggingfromrejectedimportconsumerfromtornadoimportgenfromtornadoimporthttpclientclassAsyncExampleConsumer(consumer.Consumer):@gen.coroutinedefprocess(self):LOGGER.debug('Message: %r',self.body)http_client=httpclient.AsyncHTTPClient()results=yield[http_client.fetch('http://www.github.com'),http_client.fetch('http://www.reddit.com')]LOGGER.info('Length: %r',[len(r.body)forrinresults])

示例配置

%YAML1.2---Application:poll_interval:10.0stats:log:Trueinfluxdb:enabled:Truescheme:httphost:localhostport:8086user:usernamepassword:passworddatabase:dbnamestatsd:enabled:Truehost:localhostport:8125prefix:applications.rejectedConnections:rabbitmq:host:localhostport:5672user:guestpass:guestssl:Falsevhost:/heartbeat_interval:300Consumers:example:consumer:rejected.example.Consumersentry_dsn:https://[YOUR-SENTRY-DSN]connections:-name:rabbitmq1consume:Truedrop_exchange:dlxnameqty:2queue:generated_messagesqos_prefetch:100ack:Truemax_errors:100config:foo:Truebar:bazDaemon:user:rejectedgroup:daemonpidfile:/var/run/rejected/example.%(pid)s.pidLogging:version:1formatters:verbose:format:"%(levelname)-10s%(asctime)s%(process)-6d%(processName)-25s%(name)-20s%(funcName)-25s:%(message)s"datefmt:"%Y-%m-%d%H:%M:%S"verbose_correlation:format:"%(levelname)-10s%(asctime)s%(process)-6d%(processName)-25s%(name)-20s%(funcName)-25s:%(message)s{CID%(correlation_id)s}"datefmt:"%Y-%m-%d%H:%M:%S"syslog:format:"%(levelname)s<PID%(process)d:%(processName)s>%(name)s.%(funcName)s:%(message)s"syslog_correlation:format:"%(levelname)s<PID%(process)d:%(processName)s>%(name)s.%(funcName)s:%(message)s{CID%(correlation_id)s)"filters:correlation:'()':rejected.log.CorrelationFilter'exists':Trueno_correlation:'()':rejected.log.CorrelationFilter'exists':Falsehandlers:console:class:logging.StreamHandlerformatter:verbosedebug_only:falsefilters:[no_correlation]console_correlation:class:logging.StreamHandlerformatter:verbose_correlationdebug_only:falsefilters:[correlation]syslog:class:logging.handlers.SysLogHandlerfacility:daemonaddress:/var/run/syslogformatter:syslogfilters:[no_correlation]syslog_correlation:class:logging.handlers.SysLogHandlerfacility:daemonaddress:/var/run/syslogformatter:syslogfilters:[correlation]loggers:helper:level:INFOpropagate:truehandlers:[console,console_correlation,syslog,syslog_correlation]rejected:level:INFOpropagate:truehandlers:[console,console_correlation,syslog,syslog_correlation]tornado:level:INFOpropagate:truehandlers:[console,console_correlation,syslog,syslog_correlation]disable_existing_loggers:trueincremental:false

版本历史记录

可在https://rejected.readthedocs.org/en/latest/history.html