FilesExpand file tree

 master

/

coords.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

40 lines (33 loc) · 1.14 KB

 master

/

coords.py

Copy path

Top

File metadata and controls

• Code
• Blame

40 lines (33 loc) · 1.14 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

import urllib

import urllib2

import json

import java.io

from org.apache.commons.io import IOUtils

from java.nio.charset import StandardCharsets

from org.apache.nifi.processor.io import StreamCallback

from org.python.core.util import StringUtil

class ModJSON(StreamCallback):

def __init__(self):

pass

def process(self, inputStream, outputStream):

try:

text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)

reply=json.loads(text)

reply['coords']=str(reply['lat'])+","+str(reply['lng'])

d=reply['created_at'].split("T")

reply['opendate']=d[0]

outputStream.write(bytearray(json.dumps(reply, indent=4).encode('utf-8')))

except:

global errorOccurred

errorOccurred=True

outputStream.write(bytearray(json.dumps(reply, indent=4).encode('utf-8')))

errorOccurred=False

flowFile = session.get()

if (flowFile != None):

flowFile = session.write(flowFile, ModJSON())

#flowFile = session.putAttribute(flowFile)

if(errorOccurred):

session.transfer(flowFile, REL_FAILURE)

else:

session.transfer(flowFile, REL_SUCCESS)

session.commit()