FilesExpand file tree

 master

/

QuerySCFArchived.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

39 lines (32 loc) · 1.15 KB

 master

/

QuerySCFArchived.py

Copy path

Top

File metadata and controls

• Code
• Blame

39 lines (32 loc) · 1.15 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

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:

param = {'place_url':'bernalillo-county','per_page':'100','status':'Archived'}

url = 'https://seeclickfix.com/api/v2/issues?' + urllib.urlencode(param)

rawreply = urllib2.urlopen(url).read()

reply = json.loads(rawreply)

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