OpenSearch 目标
摄取与处理
数据源

应用 / 服务

  • 应用日志 / 指标 / 追踪
  • 业务事件 / Clickstream

AWS 服务

  • CloudWatch Logs / Metrics
  • CloudTrail
  • S3(批量)/ DynamoDB Streams / RDS

流式平台

  • Amazon MSK(Kafka)
  • Kinesis Data Streams

其他

  • 自建代理 / 采集器
  • 第三方 SaaS

OpenSearch Ingestion(Data Prepper 托管)

  • Ingest/Processor/Sink 管道
  • OTel Logs/Metrics/Traces

Kinesis Data Firehose

  • 无服务器投递到 OpenSearch / S3

代理与采集器

  • Logstash / Beats / Fluent Bit / Fluentd
  • OpenTelemetry Collector

批处理

  • S3 批量(Lambda/Glue)
  • 重建/回填

数据摄取与生态集成

预置型 Domain/域

  • 热/温/冷层级存储
  • 索引/搜索/分析

Serverless Collections/集合

  • Index/Search OCU 自动扩缩
  • 多类型集合(Search/TS/Vector)

消费与洞察

  • OpenSearch Dashboards / API / Athena
  • 警报/告警集成(CloudWatch/SNS)
OTel/HTTP原生集成Kafka/KinesisS3 批处理Sink: Domain投递Sink: Serverless查询/可视化