无法从 StreamSets Jython Evaluator 写入数据答案

【问题标题】：Unable to write data from StreamSets Jython Evaluator无法从 StreamSets Jython Evaluator 写入数据
【发布时间】：2018-09-11 03:37:59
【问题描述】：

我正在尝试从目录中读取数据并尝试解析该数据并最终尝试将其写入另一个目录。

为此，我正在使用 Jython Evaluator。这是我的代码：

import sys
sys.path.append('/usr/lib/python2.7/site-packages')
import feedparser

for record in records:
  myfeed = feedparser.parse(str(record))
  for item in myfeed['items']:
    title = item.title
    link = item.link
  output.write(record)

我可以将数据写入输出，但我的要求是写入从输入记录中解析的标题和链接。

这是我的代码 sn-p：

请有任何建议。

提前致谢。

【问题讨论】：

你想解析什么？我认为str(record) 不会给您任何有用的信息 - 您的输入数据是否在记录的某个字段中？

标签： python jython streamsets

【解决方案1】：

您需要将值写入记录，请参见下面我们分别添加记录值并分配标题和链接的位置。

import sys
sys.path.append('/usr/lib/python2.7/site-packages')
import feedparser

for record in records:
  myfeed = feedparser.parse(str(record))
  for item in myfeed['items']:
    record.value["title"] = item.title
    record.value["link"] = item.link
  output.write(record)

【讨论】：