数据接入

MoleSignal 支持原生及协议兼容采集，因此许多现有 Agent 与 SDK 只需少量配置即可发送数据。除推送型 connector（用 connector token）外，每个接入端点都需 Authorization: Bearer <jwt> 认证（或使用 API token，见安全）。

支持的协议

协议	端点	兼容发送端
OTLP gRPC	`:4317`	OpenTelemetry SDK / Collector
OTLP HTTP	`POST /api/v1/logs`、`/metrics`、`/traces`	OTel HTTP exporter
Prometheus remote_write	`POST /api/v1/prometheus/api/v1/write`	Prometheus / VictoriaMetrics
Elasticsearch `_bulk`	`POST /api/v1/_bulk`	Filebeat、Vector ES sink、Logstash
Loki JSON push	`POST /api/v1/loki/api/v1/push`	能发送 Loki JSON 请求结构的客户端
Kinesis Firehose	`POST /api/v1/_kinesis_firehose`	AWS Firehose
Cloudflare Logpush	`POST /api/v1/_cloudflare`	Cloudflare Logpush
Heroku log drain	`POST /api/v1/_heroku`	Heroku
原生 HTTP JSON	`POST /api/v1/intake/{type}/{stream}`	curl / 应用 SDK

Kinesis Firehose、Cloudflare Logpush、Heroku log drain 按源单独配置——见 Connector 指南。

原生 HTTP JSON

最简单的方式。把一个记录数组 POST 到 intake/{logs,metrics,traces}/{stream}。时间戳为 Unix 纪元起的微秒数，放在 _timestamp 字段。

curl -X POST http://localhost:5080/api/v1/intake/logs/app \
  -H "authorization: Bearer $MS_JWT" \
  -H 'content-type: application/json' \
  -d '[{"_timestamp":1700000000000000,"level":"error","msg":"db pool exhausted","trace_id":"abc123"}]'

流在首次写入时创建，schema 随新字段出现自动演进。

OpenTelemetry

OTLP HTTP
OTLP gRPC

把 OTel HTTP exporter 指向 MoleSignal：

exporters:
  otlphttp:
    endpoint: http://localhost:5080/api/v1
    headers:
      authorization: "Bearer ${MS_JWT}"

日志、指标、追踪分别 POST 到 /api/v1/logs、/api/v1/metrics、/api/v1/traces。

对外标准 OTLP gRPC Receiver 默认监听 4317 端口：

exporters:
  otlp:
    endpoint: localhost:4317
    headers:
      authorization: "Bearer ${MS_JWT}"

5082 端口保留给可信内部集群 gRPC，不应作为公开 OTLP 端点。

Prometheus remote_write

在 prometheus.yml 中把 MoleSignal 加为远程写入目标：

remote_write:
  - url: http://localhost:5080/api/v1/prometheus/api/v1/write
    authorization:
      credentials: "${MS_JWT}"

Loki 与 Elasticsearch

POST /api/v1/loki/api/v1/push
# 只接受 JSON 请求结构，不解析 snappy-protobuf。

POST /api/v1/_bulk
# 适配 Filebeat、Logstash 与 Vector ES sink。

Loki 端点接受 {"streams":[{"stream":{...},"values":[["<unix_nano>","<line>"]]}]}。通过 stream-name 选择 MoleSignal 日志流。请把发送端配置为 JSON，而不是 Loki 默认的 snappy-protobuf 编码。

管道函数（Pipeline functions）

可在接入热路径上用管道函数转换事件。管道函数是挂在管道步骤上的可复用变换。运行时支持：

VRL —— 始终可用。按 (function_id, updated_at) 编译，使用 vrl::compiler 标准库（del、parse_json、to_int、match、encrypt/decrypt 等）。
JavaScript —— 可选，基于 deno_core（V8）。只有二进制使用 --features js-runtime 构建时可用，没有运行时 TOML 开关。
LLM 评估 —— 适合低吞吐流水线；需设置 [functions].llm_eval_enabled = true，且组织内有已启用的模型供应商。每条事件都会触发一次模型请求。

JS isolate 刻意做得极简：没有 fetch、setTimeout、import、npm。每个事件有 50 ms 墙钟预算与 32 MiB 堆。任何超出单次同步执行的逻辑在设计上都不支持。

// 把 `severity` 字段小写化，写入新的 `level` 字段。
molesignal.set("level", molesignal.fields.severity.toLowerCase());
// 删除一个敏感字段。
molesignal.del("pw");

快速上手

观察

可靠性

AI 运维

数据

协作

管理

部署与运维

支持的协议

原生 HTTP JSON

OpenTelemetry

Prometheus remote_write

Loki 与 Elasticsearch

管道函数（Pipeline functions）

​支持的协议

​原生 HTTP JSON

​OpenTelemetry

​Prometheus remote_write

​Loki 与 Elasticsearch

​管道函数（Pipeline functions）

支持的协议

原生 HTTP JSON

OpenTelemetry

Prometheus remote_write

Loki 与 Elasticsearch

管道函数（Pipeline functions）