# 获取rmq数据

**Repository Path**: PingTaiYanFa/get_rmq_data

## Basic Information

- **Project Name**: 获取rmq数据
- **Description**: No description available
- **Primary Language**: Java
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2018-11-01
- **Last Updated**: 2023-01-11

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

## 能力说明

### 功能简介
从指定的RMQ上获取指定topic下、指定tag的数据




### 配置参数
| 参数名称 | 参数类型 | 是否必填 | 默认值 | 参数说明 |
| - | - | - | - | - |
| 订阅topic | 文本 | 是 | 无 | 订阅的topic |
| 订阅tag | 文本 | 是 | * | 过滤的tag |
| 消费方式| 文本 | 是 | 从尾开始 | 消费RMQ数据的方式，默认消费最新 |
| 是否需要解压| 文本 | 是 | 需要 | 从RMQ消费到的数据是否需要解压 |
| 高级配置| 文本 | 否 | {"subscribe_start_time":""} | ①选择从指定时间开始消费时，设置起始消费时间subscribe_start_time：yyyy-MM-dd hh:mm:ss②自定义RMQ地址rmq_addr |




### 输入简介

该能力不需要输入



### 输入数据样例

无



### 输出简介

订阅到的数据



### 输出数据样例

无


### 相关能力

无




### 参考指标
+ 数据质量：99.9% 

+ 处理性能：8k/分钟 


-  **测试环境** 

| CPU | 内存 | 线程数 |
| --- |--- | --- |
| 4核 | 4g | 4 | 

-  **效率** 

| 运行时间 | 处理条数 |
| ------------ | ------------ |
| 前5分钟 | 处理37136条 |
| 第10分钟 | 处理66009 |
| 第15分钟 | 处理10w |




### 附加说明

无

### 隐藏参数说明

无