# GoPipeline - 数据管道
GoPipeline是一个被设计用来消息分派和处理的框架。
它用于艾润物联大数据系统的数据源采集前端,将Http WebHook、WebSocket等消息数据源,
通过GoPipeline内部转换数据格式,并分派到Spark、Kafka、WebSocketServer等其它服务。
没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
GoPipeline是一个被设计用来消息分派和处理的框架。 它用于艾润物联大数据系统的数据源采集前端,将Http WebHook、WebSocket等消息数据源, 通过GoPipeline内部转换数据格式,并分派到Spark、Kafka、WebSocketServer等其它服务。. 各领域数据集,工具源码,适合毕业设计、课程设计作业,所有源码均经过严格测试,可以直接运行,可以放心下载使用。有任何使用问题欢迎随时与博主沟通,第一时间进行解答! 软件开发设计:PHP、QT、应用软件开发、系统软件开发、移动应用开发、网站开发C++、Java、python、web、C#等语言的项目开发与学习资料 硬件与设备:单片机、EDA、proteus、RTOS、包括计算机硬件、服务器、网络设备、存储设备、移动设备等 操作系统:LInux、IOS、树莓派、安卓开发、微机操作系统、网络操作系统、分布式操作系统等。此外,还有嵌入式操作系统、智能操作系统等。 云计算与大数据:数据集、包括云计算平台、大数据分析、人工智能、机器学习等,云计算是一种基于互联网的计算方式,通过这种方式,共享的软硬件资源和信息可以按需提供给计算机和其他设备。
资源推荐
资源详情
资源评论
收起资源包目录
GoPipeline是一个被设计用来消息分派和处理的框架。 它用于艾润物联大数据系统的数据源采集前端,将Http WebHook、WebSocket等消息数据源, 通过GoPipeline内部转换数据格式,并分派到Spark、Kafka、WebSocketServer等其它服务。.zip (73个子文件)
cm
decoder.go 1KB
json.go 738B
INPUTS.md 2KB
sql
mysql_input.go 4KB
abc
abc_scheduler.go 726B
abc_shutdown.go 1KB
Gopkg.toml 645B
Makefile 1KB
abc_slot.go 688B
OUTPUTS.md 717B
globals.go 386B
find.go 3KB
json_test.go 347B
Gopkg.lock 8KB
data_frame_pool.go 865B
TOPIC_RULE.md 1KB
config.go 2KB
cmd
startup.sh 318B
ctrl.go 114B
conf.d
config.toml 713B
outputs.toml 568B
inputs.toml 926B
stats.toml 594B
main.go 4KB
matcher.go 2KB
.idea
vcs.xml 180B
modules.xml 274B
go-pipeline.iml 322B
filter.go 2KB
http
http_server_input.go 3KB
ws_server_output.go 6KB
auth.go 4KB
ws_client_input.go 3KB
server.go 2KB
x_performance.go 1KB
x_atomic.go 475B
input.go 2KB
multi_reader.go 2KB
ringsamp_test.go 497B
router.go 13KB
common
count_input.go 2KB
meminfo_decoder.go 1KB
file_input.go 2KB
mock_input.go 2KB
console_output.go 837B
data_frame_test.go 486B
data_frame.go 3KB
TODO.md 193B
x_time.go 532B
splitter
x_delimiter.go 759B
stream_splitter.go 1KB
stream_splitter_test.go 475B
bytes_splitter.go 1KB
splitter.go 1KB
scanner_splitter.go 760B
abc_splitter.go 842B
bytes_splitter_test.go 692B
.gitignore 1KB
matcher_test.go 2KB
bench
benchmark.sh 162B
.gitignore 50B
conf.d
config.sample.toml 1018B
hooks
terminate_report.go 952B
util
math.go 425B
class.go 394B
secret.go 2KB
README.md 314B
x_counter.go 969B
components.go 1KB
output.go 974B
registry.go 3KB
kafka
kafka_output.go 3KB
ringsamp.go 801B
共 73 条
- 1
资源评论
妄北y
- 粉丝: 9780
- 资源: 1万+
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- 基于STM32F103C8T6单片机蓄电池在线监测系统主板硬件(原理图+PCB)工程文件.zip
- mysql大纲资料.txt
- c++大纲资料.txt
- 效率工具bat脚本实现日志提取
- MyBatis 中动态 SQL 的示例
- STM8L101F3P6单片机+CC1100模块433M遥控器设计硬件(原理图+PCB)工程文件.zip
- 上传下载铁人下载系统 Liuxing 1.0-liuxing1.0.rar
- 南京邮电大学数学实验实力雄厚,凭借其优秀的师资力量、丰富的实践教学资源和卓越的科研成果,成为国内一流的数学实验教学和科研基地
- 【火爆朋友圈的今天吃什么源码 v1.0】随机的为用户带来每一天的用餐选择和推荐.rar
- MPU6050中文版数据手册
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功