Download the PHP package rabbit/data-pipeline without Composer
On this page you can find all versions of the php package rabbit/data-pipeline. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
Please rate this library. Is it a good library?
Informations about the package data-pipeline
STS流处理
- 基于插件的流程处理组件
组件配置
任务配置
通用配置
type
插件完整类名start
是否开始插件,默认false
output
输出到下一个插件,支持Http
输出到远程插件,worker
多进程任务,格式PluginName String|(http|worker):address:PluginName String
,默认不等待['PluginName String|(http|worker):address:PluginName String':true|false|int]
- PS:
true
启用协程等待,不设超时;int
启用协程等待,值为超时时间;false
不等待
- PS:
errHandler
错误处理函数
内置插件
Sources
- Amqp
- FindFiles
- Http
- Nsq
- Pdo
- RdKafka
Common
- HttpRequest
TransForms
- LineParser
Sinks
- Amqp
- Clickhouse
- Console
- File
- Nsq
- Pdo
- RdKafka
插件开发
- 继承
AbstractPlugin
- 实现
run
函数 - 通过
init
从$this->config
中获取配置参数初始化配置属性 - 插件间传值通过
Message
类,开启协程传递需要clone Message
,输出值赋值到克隆的Message->data
属性 - PS:配置属性禁止在运行过程中修改,插件为单例模式,协程环境下会造成属性污染。可使用局部变量替代,例如
$name=$this->name
,使用$name
All versions of data-pipeline with dependencies
PHP Build Version
Package Version
Requires
rabbit/framework Version
^1.0
rabbit/server Version ^1.0
rabbit/parser Version ^1.0
rabbit/httpclient Version ^1.0
rabbit/server Version ^1.0
rabbit/parser Version ^1.0
rabbit/httpclient Version ^1.0
The package rabbit/data-pipeline contains the following files
Loading the files please wait ....