info_message
Normal
0
/
input_db_ip
172.17.0.1
input_db_port
27017
out_db_ip
172.17.0.1
out_db_name
ry
out_db_port
3306
out_db_pwd
sckjadmin
out_db_username
root
ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
TRANSNAME
Y
TRANSNAME
STATUS
Y
STATUS
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
STARTDATE
Y
STARTDATE
ENDDATE
Y
ENDDATE
LOGDATE
Y
LOGDATE
DEPDATE
Y
DEPDATE
REPLAYDATE
Y
REPLAYDATE
LOG_FIELD
Y
LOG_FIELD
EXECUTING_SERVER
N
EXECUTING_SERVER
EXECUTING_USER
N
EXECUTING_USER
CLIENT
N
CLIENT
ID_BATCH
Y
ID_BATCH
SEQ_NR
Y
SEQ_NR
LOGDATE
Y
LOGDATE
TRANSNAME
Y
TRANSNAME
STEPNAME
Y
STEPNAME
STEP_COPY
Y
STEP_COPY
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
INPUT_BUFFER_ROWS
Y
INPUT_BUFFER_ROWS
OUTPUT_BUFFER_ROWS
Y
OUTPUT_BUFFER_ROWS
ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
LOGGING_OBJECT_TYPE
Y
LOGGING_OBJECT_TYPE
OBJECT_NAME
Y
OBJECT_NAME
OBJECT_COPY
Y
OBJECT_COPY
REPOSITORY_DIRECTORY
Y
REPOSITORY_DIRECTORY
FILENAME
Y
FILENAME
OBJECT_ID
Y
OBJECT_ID
OBJECT_REVISION
Y
OBJECT_REVISION
PARENT_CHANNEL_ID
Y
PARENT_CHANNEL_ID
ROOT_CHANNEL_ID
Y
ROOT_CHANNEL_ID
ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
TRANSNAME
Y
TRANSNAME
STEPNAME
Y
STEPNAME
STEP_COPY
Y
STEP_COPY
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
LOG_FIELD
N
LOG_FIELD
ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
METRICS_DATE
Y
METRICS_DATE
METRICS_CODE
Y
METRICS_CODE
METRICS_DESCRIPTION
Y
METRICS_DESCRIPTION
METRICS_SUBJECT
Y
METRICS_SUBJECT
METRICS_TYPE
Y
METRICS_TYPE
METRICS_VALUE
Y
METRICS_VALUE
0.0
0.0
100000
50
50
N
Y
50000
Y
N
1000
100
-
2020/07/28 20:03:36.581
-
2020/07/28 20:03:36.581
H4sIAAAAAAAAAAMAAAAAAAAAAAA=
N
ry_info
${out_db_ip}
MYSQL
Native
${out_db_name}
${out_db_port}
${out_db_username}
${out_db_pwd}
EXTRA_OPTION_MYSQL.characterEncoding
UTF-8
EXTRA_OPTION_MYSQL.defaultFetchSize
500
EXTRA_OPTION_MYSQL.useCursorFetch
true
FORCE_IDENTIFIERS_TO_LOWERCASE
N
FORCE_IDENTIFIERS_TO_UPPERCASE
N
IS_CLUSTERED
N
PORT_NUMBER
${out_db_port}
PRESERVE_RESERVED_WORD_CASE
Y
QUOTE_ALL_FIELDS
N
STREAM_RESULTS
Y
SUPPORTS_BOOLEAN_DATA_TYPE
Y
SUPPORTS_TIMESTAMP_DATA_TYPE
Y
USE_POOLING
N
MongoDB input
表输出
Y
MongoDB input
插入 / 更新
N
MongoDB input
MongoDbInput
Y
1
none
${input_db_ip}
${input_db_port}
N
info_admin
value
json
{ $sort: { time: -1 } },{ $lookup: { from: 'info', localField: 'infoId', foreignField: '_id', as: 'info' } },
{ $unwind: { path: '$info', preserveNullAndEmptyArrays: true } },
{ $lookup: { from: 'sys_dept', localField: 'dept2', foreignField: '_id', as: 'deptName2' } },
{ $unwind: { path: '$deptName2', preserveNullAndEmptyArrays: true } },
{ $lookup: { from: 'sys_dept', localField: 'dept3', foreignField: '_id', as: 'deptName3' } },
{ $unwind: { path: '$deptName3', preserveNullAndEmptyArrays: true } },
{ $project: {
dept1:1,dept2:1,dept3:1,dept4:1,dept5:1,deptName2:'$deptName2.name',deptName3:'$deptName3.name',infoName:'$info.name',type:1,
date: { $dateToString: { format: "%Y-%m-%d", date: "$time" } },
time: { $dateToString: { format: "%H:%M", date: "$time", timezone: '+08:00' } },
yuanType: '$info.oldType',
'oldType.type': {
$slice: ['$info.oldType', 1]
},
} },
{ $unwind: { path: '$oldType.type', preserveNullAndEmptyArrays: true } },
{
$project: {
dept1:1,dept2:1,dept3:1,dept4:1,dept5:1,yuanType:1,
date: 1,
time: 1,
oldType: {$toString: '$oldType.type'},
address: {
$concat: [ '$deptName2', '$deptName3',
{$toString: '$oldType.type'},
'$infoName',
{$cond: { if: { $eq: [ '$type', "0" ] },then:
"采集数据管理员审核完成", else: "探访完成",
},}
] },
},},
{ $limit: 100 },
Encrypted
N
N
primary
N
Y
N
_id
$._id
String
address
$.address
String
time
$.time
String
date
$.date
String
dept5
$.dept5
String
dept1
$.dept1
String
dept2
$.dept2
String
dept3
$.dept3
String
dept4
$.dept4
String
208
272
Y
插入 / 更新
InsertUpdate
Y
1
none
ry_info
100
N
ry
_id
infoId
=
infoId
_id
Y
address
address
Y
time
time
Y
data
date
Y
dept5
dept5
Y
dept1
dept1
Y
dept2
dept2
Y
dept3
dept3
Y
dept4
dept4
Y
544
304
Y
表输出
TableOutput
Y
1
none
ry_info
ry
10000
Y
N
Y
Y
N
N
Y
N
Y
N
address
address
time
time
data
date
dept5
dept5
dept1
dept1
dept2
dept2
dept3
dept3
dept4
dept4
infoId
_id
496
240
Y
N