fbeltrao/httpstreamer

fbeltrao/httpstreamer镜像说明

镜像概述

fbeltrao/httpstreamer是基于.NET Core的通用HTTP监听器镜像，核心功能是接收HTTP请求并将JSON消息转发至Azure Event Hub，支持本地运行与Azure容器实例部署。

核心功能

• 监听HTTP请求并处理JSON格式数据
• 将JSON消息可靠发送至指定Azure Event Hub
• 通过环境变量灵活配置连接信息及目标资源

使用场景

• 实时数据采集：对接外部HTTP数据源，将JSON消息转发至Event Hub进行后续分析
• 云原生集成：作为中间件连接HTTP服务与Azure Event Hub，实现数据流转
• 测试验证：快速部署以验证Event Hub的数据接收流程

配置说明

需配置以下环境变量：

• HTTPSTREAM_EVENTHUB：Azure Event Hub的连接字符串（必填项）
• HTTPSTREAM_URL：目标HTTP资源路径（例如/2/open_events）
• HTTPSTREAM_HOST：目标HTTP主机（例如stream.meetup.com）

部署示例

本地Docker运行

bash
docker run -t -d \
  --env HTTPSTREAM_EVENTHUB="{event hub connection string}" \
  --env HTTPSTREAM_URL="/2/open_events" \
  --env HTTPSTREAM_HOST="stream.meetup.com" \
  fbeltrao/httpstreamer:0.3

查看本地容器日志

bash
docker logs -t -f {容器ID}

Azure容器实例部署

bash
az container create \
  -g <资源组名称> \
  --name <容器实例名称> \
  --image fbeltrao/httpstreamer:0.3 \
  --environment-variables HTTPSTREAM_EVENTHUB="<event hub connection string>" HTTPSTREAM_URL="/2/open_events" HTTPSTREAM_HOST="stream.meetup.com" \
  --location <Azure区域>

检查Azure容器部署状态

bash
az container list -o table

查看Azure容器日志

bash
az container logs -g <资源组名称> -n <容器实例名称>

源代码

镜像基于.NET Core项目构建，源代码地址：https://github.com/fbeltrao/HttpStreamer