Tormenta分布式系统的脚本包
Tormenta 是 Storm 分布式计算机系统的 Scala 扩展包。Tormenta 在 Storm 的 Kafka 和 Kestrel spouts消息 上添加了一个安全类型的包装器。此安全类型允许用户推送映射消息和筛选转换信息到 spout 消息层上去。
代码示例:
import com.twitter.tormenta.scheme._ import com.twitter.tormenta.spout._ // produces strings: val scheme: Scheme[String] = Scheme { bytes => Some(new String(bytes)) } // produces integers w/ string length: val mappedScheme: Scheme[Int] = scheme.map(_.length) // filters out all tuples less than 5: val filteredScheme: Scheme[Int] = mappedScheme.filter(_ > 5) // produces lengths for input strings > length of 5 val spout: KestrelSpout[Int] = new KestrelSpout(filteredScheme, hostSeq, "spout")
评论
JaegerUber 的分布式追踪系统
Jaeger是受Dapper和OpenZipkin的启发,由UberTechnologies创建的分布式追踪平台,现已捐赠给云原生计算基金会。它可用于监视基于微服务的分布式系统:分布式上下文传播分布式
JaegerUber 的分布式追踪系统
0
iBase4J分布式系统
Springboot,Spring,SpringMVC,Mybatis,mybatis-plus,motan/dubbo分布式,Redis缓存,Shiro权限管理,Spring-Session单点登录
iBase4J分布式系统
0