|
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
|
import
java.io
from datetime
import
datetime
from org.apache.commons.io
import
IOUtils
from java.nio.charset
import
StandardCharsets
from org.apache.nifi.processor.io
import
StreamCallback
class
GetDate(StreamCallback):
def __init__(self):
pass
def process(self, inputStream, outputStream):
#text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
dt =
''
months = [
1
,
4
,
7
,
10
]
for
year in range(
1990
,
2016
):
for
i in range(len(months)):
dt1 = datetime(year, months[i],
1
,
0
,
0
,
0
)
if
months[i] ==
10
:
dt2 = datetime(year+
1
,
1
,
1
,
0
,
0
,
0
)
else
:
dt2 = datetime(year, months[i]+
3
,
1
,
0
,
0
,
0
)
dt += dt1.strftime(
"%Y-%m-%d %H:%M:%S"
) +
','
+ dt2.strftime(
"%Y-%m-%d %H:%M:%S"
) +
";"
outputStream.write(dt)
flowFile = session.create()
if
(flowFile != None):
flowFile = session.write(flowFile, GetDate())
#flowFile = session.putAttribute(flowFile,
"filename"
, flowFile.getAttribute(
'filename'
).split(
'.'
)[
0
]+
'_translated.json'
)
session.transfer(flowFile, REL_SUCCESS)
session.commit()
|
本文转自疯吻IT博客园博客，原文链接：http://www.cnblogs.com/fengwenit/p/6170180.html，如需转载请自行联系原作者
