首页
前端开发
Typescript
Mutator-IO: 用于数据转换的轻量级管道库

Mutator-IO: 用于数据转换的轻量级管道库

22 次浏览 0 条评论
zip
zip

Mutator-IO 是一个专注于数据处理的精简库。它采用组合的方式，通过管道将数据从源头 (InputStream) 传输到目标 (OutputStream)。

管道 (Pipe)

在 Mutator-IO 中，管道遵循以下接口定义：

interface Pipe {
  name: string;
  in: InputStream;
  out: OutputStream;
}

示例：

import { MutatorIO } from 'mutator-io';
import * as MqttInputStream from 'mutator-io-plugin-mqtt';
import * as DynamoDBOutputStream from 'mutator-io-plugin-out-dynamodb';

const mutator = new MutatorIO();

// ... 使用插件配置输入和输出 ...

mutator.pipe(MqttInputStream).pipe(DynamoDBOutputStream);

mutator.start();

上述代码片段展示了如何使用 Mutator-IO 将数据从 MQTT 输入流传输到 DynamoDB 输出流。

zip 文件大小：216.98KB