instructure/kinesis2sqs Docker Image Overview

instructure/kinesis2sqs

instructure

基于Ruby的Docker应用镜像，用于从Kinesis拉取消息并推送到SQS，主要在开发环境中模拟Live Events消息系统。

0 次下载

🚀 生产环境还在裸拉官方镜像？一次故障=一次通宵

中文简介版本下载

🚀 生产环境还在裸拉官方镜像？一次故障=一次通宵

Kinesis2Sqs镜像文档

镜像概述和主要用途

Kinesis2Sqs是一个基于Ruby的Docker应用镜像，核心功能是从Kinesis流拉取消息并将其推送到SQS队列。该镜像主要用于开发环境，帮助模拟依赖Kinesis和SQS的Live Events消息系统，便于开发和测试相关应用功能。

核心功能和特性

消息转发：从指定的Kinesis流中拉取消息，并将消息推送至指定的SQS队列
灵活配置：通过环境变量配置Kinesis和SQS的连接信息、轮询间隔等参数
开发环境适配：支持对接本地Kinesis模拟服务（如kinesalite）和SQS模拟服务（如elasticmq）

使用场景和适用范围

适用于需要在本地开发或测试环境中模拟Kinesis到SQS消息流转的场景，帮助开发人员在不依赖AWS云服务的情况下，验证消息处理逻辑。

使用方法和配置说明

环境变量配置

环境变量	说明
`SLEEP_LENGTH`	消息拉取和推送的轮询间隔时间（秒），默认值未指定，需根据需求配置
`AWS_REGION`	AWS区域，如`us-east-1`
`AWS_ACCESS_KEY`	AWS访问密钥（开发环境可使用模拟密钥）
`AWS_SECRET_ACCESS_KEY`	AWS密钥（开发环境可使用模拟密钥）
`AWS_KINESIS_ENDPOINT`	Kinesis服务端点，对接本地模拟服务时填写如`[***]`
`AWS_KINESIS_STREAM_NAME`	要拉取消息的Kinesis流名称，如`quiz-live-events`
`AWS_SQS_ENDPOINT`	SQS服务端点，对接本地模拟服务时填写如`[***]`
`AWS_SQS_QUEUE_NAME`	要推送消息的SQS队列名称，如`queue1`

部署示例（docker-compose配置）

以下是完整的docker-compose.yml配置示例，包含Kinesis2Sqs服务及依赖的Kinesis、SQS模拟服务：

yaml
version: '3'  # 根据实际需求调整compose版本

services:
  # Kinesis2Sqs服务：拉取Kinesis消息并推送到SQS
  kinesis2sqs:
    image: instructure/kinesis2sqs
    environment:
      SLEEP_LENGTH: 5  # 每5秒轮询一次
      AWS_REGION: us-east-1
      AWS_ACCESS_KEY: x  # 开发环境模拟密钥，无需真实密钥
      AWS_SECRET_ACCESS_KEY: x  # 开发环境模拟密钥，无需真实密钥
      AWS_KINESIS_ENDPOINT: [***]  # 对接本地Kinesis模拟服务
      AWS_KINESIS_STREAM_NAME: quiz-live-events  # 目标Kinesis流名称
      AWS_SQS_ENDPOINT: [***]  # 对接本地SQS模拟服务
      AWS_SQS_QUEUE_NAME: queue1  # 目标SQS队列名称
    depends_on:  # 依赖kinesis和elasticmq服务启动后再启动
      - kinesis
      - elasticmq

  # Kinesis模拟服务：使用kinesalite提供本地Kinesis服务
  kinesis:
    image: instructure/kinesalite
    ports:
      - "4567:4567"  # 暴露4567端口供本地访问

  # SQS模拟服务：使用elasticmq提供本地SQS服务
  elasticmq:
    image: instructure/elasticmq
    ports:
      - "9324:9324"  # 暴露9324端口供本地访问