小编Yu *_*abe的帖子

在 apache beam python sdk 中，我经常在管道过程中看到“>>”运算符。

https://beam.apache.org/documentation/programming-guide/#pipeline-io

lines = p | 'ReadFromText' >> beam.io.ReadFromText('path/to/input-*.csv')

这是什么意思？

我想获得ruby过滤器中代码的帮助.

logstash版本是5.0.0 alpha4.

我正在测试ruby过滤器中的代码,如下所示,但我得到_rubyexception.

  ruby {
    code => "
      event['newfield'] = 'test'
    "
  }

ruby过滤器在filter {}中定义.logstash.log显示如下,

:timestamp=>"2016-08-03T15:26:47.291000+0900", :message=>"Ruby exception occurred: undefined method[]=' for 2016-08-03T06:26:46.829Z test %{message}:LogStash::Event", :level=>:error}

我找不到ruby过滤器无法使用事件对象的原因.如果能得到一些帮助来解决这个问题我很感激.

谢谢,余