Невозможно записать данные из StreamSets Jython Evaluator - PullRequest
Новая
       13

Невозможно записать данные из StreamSets Jython Evaluator

0 голосов
/ 11 сентября 2018

Я пытаюсь прочитать данные из каталога, пытаюсь проанализировать эти данные и, наконец, пытаюсь записать их в другой каталог.

для этого я использую 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)

Я могу записать данные для вывода, но мое требование - написать заголовок и ссылку, которые анализируются из входной записи.

Вот мой фрагмент кода:

enter image description here

любые предложения, пожалуйста.

Заранее спасибо.

1 Ответ

0 голосов
/ 17 мая 2019

Вам необходимо записать значения в запись, см. Ниже, где мы добавляем значение записи и присваиваем заголовок и ссылку соответственно.

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)
...