数据源

所有信号都通过 intake API 进入 MoleSignal。网页界面中的 数据源 页面会为每个数据源生成端点、Token 和配置片段，同样的协议也可以手工配置。

数据源页面

打开 数据源 接入数据源：

在目录中搜索，或按分类筛选：推荐、基础设施、云服务、数据库、消息队列、应用与语言、安全与 自定义。信号标签（日志、指标、链路、Profiles）可以进一步缩小范围。
选择一个数据源，例如 Kubernetes、Linux 主机、AWS、OpenTelemetry SDK 或 Web RUM。
按向导的三个步骤完成接入：
- 端点与 Token 显示数据发往哪里，以及用于鉴权的 Token。显示 Token 会显示 Token 及其角色、工作区和有效期。用户体验类数据源需要先选择 RUM 应用，选择后才会显示它的 Client Token。
- 配置数据源 显示命令和配置，其中的端点与 Token 已替换为真实值。
- 验证数据到达 先检查接收端，再查看最近 1 小时内是否收到数据。验证接入 立即检查一次，各项数字每 30 秒自动刷新。
查看验证结果：
- 已检测到数据：最近 1 小时内收到了数据，且该数据源的信号都处于正常状态。查看已接收数据 打开这些数据，创建流水线 为它们创建流水线。
- 接收端正常，但数据状态需要确认：接收端有响应，但还没有收到数据，或并非所有信号都正常。请检查部署，或等待下一批数据。
- 验证失败：无法检查接收端。可能原因 列出采集器未运行、Token 无效或已过期，以及网络或代理阻断了端点。

设置了 http.external_url 时，端点取自该配置；否则取自浏览器当前地址。位于反向代理之后时，请设置 http.external_url，让生成的片段指向对外地址。参见配置。

接入 Token

发送端使用 Bearer Token 认证：Authorization: Bearer <token>。

Token	权限	创建方式	用途
默认接入 Token（`ms_…`）	仅 `streams.write` 和 `apm.deploy`	数据源页面，或 `GET /api/v1/auth/tokens/default`	发送日志、指标与链路的采集器、Agent 与 SDK 导出端，以及上报发布的流水线。不会过期。
RUM Client Token（`msrum_…`）	仅 `rum.write`，绑定一个应用	Web RUM 与移动端 RUM 数据源的数据源页面，或 `GET /api/v1/auth/tokens/rum?application_id=<id>`	浏览器与移动端代码。终端用户可以看到该 Token。
个人或服务账号 Token（`ms_…`）	所选角色的权限	身份与访问 → API tokens	自动化、脚本与 MCP 客户端。
登录 Token（JWT）	登录用户的权限	`POST /api/v1/auth/signin`	交互式使用。默认 24 小时后过期（`[auth].token_ttl_secs`）。

持续运行的发送端使用默认接入 Token 或服务账号 Token。登录 Token 到期后即失效，所有使用它的发送端都会随之中断。在 身份与访问 → API tokens 中撤销 Token 可立即使其失效。在数据源页面输入应用 id 后会创建 RUM Client Token。应用 id 由 1 到 128 个字符组成，可使用 A-Z、a-z、0-9、.、_、: 与 -。SDK 中的 applicationId 使用同一个 id，参见浏览器 RUM SDK。

端点与协议

协议	端点	兼容的发送端	目标数据流
原生 HTTP JSON	`POST /api/v1/intake/{logs,metrics,traces}/{stream}`	`curl`、应用代码、Vector `http` sink、Fluent Bit `http` 输出	路径中的 `{stream}`
OTLP over HTTP	`POST /api/v1/logs`、`/api/v1/metrics`、`/api/v1/traces`	OpenTelemetry SDK 与 Collector	`stream-name` 请求头，缺省为 `default`
OTLP over gRPC	`:4317`	OpenTelemetry SDK 与 Collector	`stream-name` 元数据，缺省为 `default`
Prometheus remote_write	`POST /api/v1/prometheus/api/v1/write`	Prometheus、VictoriaMetrics 及任何 remote_write v1 发送端	`stream-name` 请求头，否则为 `default`
Elasticsearch `_bulk`	`POST /api/v1/_bulk`	Filebeat、Logstash、Vector `elasticsearch` sink	每个 action 的 `_index`，否则 `stream-name` 请求头，否则 `default`
Loki push（JSON）	`POST /api/v1/loki/api/v1/push`	能发送 Loki JSON 格式的发送端	`stream-name` 请求头，缺省为 `default`
Kinesis Firehose、Cloudflare Logpush、Heroku	`/api/v1/_kinesis_firehose`、`/api/v1/_cloudflare`、`/api/v1/_heroku`	AWS、Cloudflare、Heroku	在连接器上配置，参见连接器

除推送型连接器外，所有端点都需要具备 streams.write 权限的 Bearer Token。组织由 Token 决定，不会出现在 URL 中。

影响发送端的限制

请求大小。 超过 2 MiB 的请求体会被拒绝并返回 413。请让每批数据小于该大小。
压缩。 OTLP over HTTP 不接受压缩的请求体，会返回 400。请在发送端关闭压缩；OpenTelemetry Collector 的 otlphttp 导出端默认使用 gzip 压缩，需要设置 compression: none。Elasticsearch _bulk、Loki push 与推送型连接器接受 Content-Encoding: gzip。
Loki 编码。 只解析 JSON 请求格式。Promtail 与 Grafana Alloy 默认发送 snappy 压缩的 protobuf，无法向该端点发送数据。
速率限制。 router 角色按组织限制请求，超限时返回 429 并附带 Retry-After 响应头。standalone 节点不应用这个限制。参见分角色部署。
保留数据流。 数据流名称 _molesignal 保留给服务自身的遥测，拒绝公开接入。

数据流与 Schema

数据流在首次写入时创建，schema 会随新字段出现而演进。数据流由名称和信号类型共同标识，因此 default 可以同时存在于日志、指标和链路类型下。参见数据流。每个事件都有一个自 Unix 纪元起的微秒时间戳。原生 JSON 与 Elasticsearch _bulk 读取 _timestamp 字段。没有 _timestamp 的事件使用服务端接收它的时间。

原生 HTTP JSON

向 /api/v1/intake/{logs,metrics,traces}/{stream} 发送记录数组：

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

响应会给出已接收与已拒绝的记录数，并为每条被拒绝的记录给出下标与原因：

{"accepted":1,"rejected":0,"errors":[]}

OpenTelemetry

把 OpenTelemetry SDK 或 Collector 指向 /api 基础路径。导出端会自动追加 /v1/logs、/v1/metrics 与 /v1/traces，对应 /api/v1/logs、/api/v1/metrics 与 /api/v1/traces。

OTLP over HTTP
OTLP over gRPC

SDK 环境变量：

export OTEL_EXPORTER_OTLP_PROTOCOL=http/protobuf
export OTEL_EXPORTER_OTLP_ENDPOINT=http://localhost:5080/api
export OTEL_EXPORTER_OTLP_HEADERS="authorization=Bearer ${MS_TOKEN}"

OpenTelemetry Collector：

exporters:
  otlphttp/molesignal:
    endpoint: http://localhost:5080/api
    compression: none
    headers:
      authorization: "Bearer ${env:MS_TOKEN}"

请发送 protobuf（application/x-protobuf），这是各 SDK 与 Collector 的默认编码。日志、指标与链路也接受 JSON（application/json）。添加 stream-name 请求头可选择 default 之外的数据流，该请求头对通过这个导出端发送的所有信号生效。

OTLP gRPC 接收端监听 4317 端口，提供日志、指标、链路与 Profiles 四个服务。它不终止 TLS，流量离开可信网络时，需要在前面终止 TLS。

export OTEL_EXPORTER_OTLP_PROTOCOL=grpc
export OTEL_EXPORTER_OTLP_ENDPOINT=http://localhost:4317
export OTEL_EXPORTER_OTLP_HEADERS="authorization=Bearer ${MS_TOKEN}"

OpenTelemetry Collector：

exporters:
  otlp/molesignal:
    endpoint: localhost:4317
    tls:
      insecure: true
    headers:
      authorization: "Bearer ${env:MS_TOKEN}"

端口前面有终止 TLS 的代理时，去掉 insecure: true。5082 是集群内部 gRPC 端口，不是 OTLP 接收端。

OTLP 指标按数据点逐条存储，存储字段参见指标存储约定。

Prometheus remote_write

在 prometheus.yml 中把 MoleSignal 添加为 remote write 目标：

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

一个指标数据流装一个来源的全部指标，所以请用 stream-name 请求头（remote_write 配置里的 headers:）给每台 Prometheus 指定自己的数据流；没有这个请求头时样本写入 default。每个样本成为一行，metric_name 是它的 __name__。其余标签成为字段，与指标字段同名的标签（例如 metric_name）存为 exported_<名称>。原生直方图与指标元数据会被跳过，exemplar 与样本一起保存。

Elasticsearch bulk

支持 Elasticsearch bulk 协议的发送端无需依赖 Loki 或 OTLP 即可使用：

curl -X POST http://localhost:5080/api/v1/_bulk \
  -H "authorization: Bearer $MS_JWT" \
  -H 'content-type: application/x-ndjson' \
  --data-binary $'{"index":{"_index":"app"}}\n{"level":"info","msg":"hello"}\n'

每个 action 的 _index 决定目标数据流。没有 _index 时使用 stream-name 请求头，再缺省为 default。

Loki push

该端点接受 Loki 的 JSON 请求格式：

{"streams":[{"stream":{"service":"checkout","level":"error"},"values":[["1700000000000000000","payment failed"]]}]}

标签成为字段，日志行写入 message 字段，纳秒时间戳会转换为微秒。响应为 204。用 stream-name 请求头选择目标数据流。

集成指南

OpenTelemetry Collector、Vector、Fluent Bit、Filebeat、Prometheus 与 Kubernetes 的完整配置。

流水线

在事件到达时或按定时计划，对事件做路由、标准化、脱敏与扩展。

连接器

接收 Kinesis Firehose、Cloudflare Logpush 与 Heroku 日志投递。

身份与访问

创建服务账号并管理 API Token。

快速上手

数据

观察

查询与关联

可靠性

AI 运维

协作

管理

部署与运维

最佳实践

资源

数据源页面

接入 Token

端点与协议

影响发送端的限制

数据流与 Schema

原生 HTTP JSON

OpenTelemetry

Prometheus remote_write

Elasticsearch bulk

Loki push

相关页面

集成指南

流水线

连接器

身份与访问

​数据源页面

​接入 Token

​端点与协议

​影响发送端的限制

​数据流与 Schema

​原生 HTTP JSON

​OpenTelemetry

​Prometheus remote_write

​Elasticsearch bulk

​Loki push

​相关页面

集成指南

流水线

连接器

身份与访问

数据源页面

接入 Token

端点与协议

影响发送端的限制

数据流与 Schema

原生 HTTP JSON

OpenTelemetry

Prometheus remote_write

Elasticsearch bulk

Loki push

相关页面