我试图在较低的级别上度量我的服务的延迟。环顾四周,我发现可以向grpc构建器添加一个addStreamTracerFactory。
我完成了这样一个简单的实现,并打印了日志:
val server = io.grpc.netty.NettyServerBuilder.forPort(ApplicationConfig.Service.bindPort).addStreamTracerFactory(ServerStreamTracerFactory)....
class Telemetry(fullMethodName: String, headers: Metadata) extends
我需要读取一个有数千行的日志文件,并将每一行写入一个Mongo数据库。我正在使用节点流读取文件。我使用“拆分”npm包将文件拆分为“行”。由于网络方面的考虑,MongoDB写入将花费比读取日志文件更长的时间。
我的核心代码如下所示:
var readableStream = fs.createReadStream(filename);
readableStream
.pipe(split()) // This splits the data into 'lines'
.on('da