bsm-lab
/
dfxagent
1
0
Fork 0
Code Issues 8 Pull Requests Packages Projects Releases Wiki Activity

데이터 저장시 설정된 건수 이상일 경우 1000건씩 나눠서 저장 기능 추가 - bsm-lab/dfxagent#7

Browse Source 
alive 메시지 로직 확인 완료 - bsm-lab/dfxagent#2
main
semin.baek 8 months ago
parent 732f655d15
commit 4b49f71a8f
3 changed files with 82 additions and 56 deletions
Show Stats Download Patch File Download Diff File

22
src/docs/settings-examples/dfxagent-bd-test-cubrid.json
Unescape View File

@ -3,9 +3,15 @@
"myHostId": "bd-test-cubrid", "myHostId": "bd-test-cubrid",
"myListenPort": 17801, "myListenPort": 17801,
"knownAgentList": [ "knownAgentList": [
{
"hostId": "bd-test-oracle",
"hostName": "192.168.0.16",
"listenPort": 17801,
"dropBoxIdList": []
}
], ],
"statusChecker": { "statusChecker": {
"cron": "0 0/10 * * * *" "cron": "2 0/1 * * * *"
}, },
"dataSourceConfig": [ "dataSourceConfig": [
{ {
@ -13,7 +19,8 @@
"driverClassName": "cubrid.jdbc.driver.CUBRIDDriver", "driverClassName": "cubrid.jdbc.driver.CUBRIDDriver",
"url": "jdbc:cubrid:14.63.185.105:33000:amif:ami::", "url": "jdbc:cubrid:14.63.185.105:33000:amif:ami::",
"username": "ami", "username": "ami",
"password": "fox12#$%" "password": "fox12#$%",
"maximumRowForTransaction": 1000
} }
], ],
"sqlMapperLocations": [ "sqlMapperLocations": [
@ -29,7 +36,8 @@
"packages": [ "packages": [
{ {
"com.bsmlab.dfx.agent": "DEBUG", "com.bsmlab.dfx.agent": "DEBUG",
"jdbc.sqlonly": "DEBUG" "jdbc.sqlonly": "DEBUG",
"org.springframework": "INFO"
} }
] ]
}, },
@ -37,6 +45,8 @@
"receivedMessageStorageRoot": "/home/dfxagent/agent/messages/received", "receivedMessageStorageRoot": "/home/dfxagent/agent/messages/received",
"processedMessageStorageRoot": "/home/dfxagent/agent/messages/processed", "processedMessageStorageRoot": "/home/dfxagent/agent/messages/processed",
"failureMessageStorageRoot": "/home/dfxagent/agent/messages/failure", "failureMessageStorageRoot": "/home/dfxagent/agent/messages/failure",
"threadPoolSize": 300,
"retentionDaysOfProcessedMessage": 60,
"dropBoxList": [ "dropBoxList": [
{ {
"dropBoxId": "db-bd-cubrid-save", "dropBoxId": "db-bd-cubrid-save",
@ -46,6 +56,8 @@
} }
] ]
}, },
"postman": [ "postmanConfig": {
] "threadPoolSize": 30,
"postmanList": []
}
} }

59
src/docs/settings-examples/dfxagent-bd-test-oracle-local.json
Unescape View File

@ -1,7 +1,7 @@
{ {
"description": "개발PC에서 실행함. 웍스테이션 에이전트(bd-test-cubrid)와 연결. 웍스테이션 oracle 에서 TTO_BD 테이블을 조회하여 bd-test-cubrid 에이전트에게 전달함", "description": "개발PC에서 실행함. 웍스테이션 에이전트(bd-test-cubrid)와 연결. 웍스테이션 oracle 에서 TTO_BD 테이블을 조회하여 bd-test-cubrid 에이전트에게 전달함",
"myHostId": "bd-test-oracle", "myHostId": "bd-test-oracle",
"myListenPort": 16801, "myListenPort": 17801,
"knownAgentList": [ "knownAgentList": [
{ {
"hostId": "bd-test-cubrid", "hostId": "bd-test-cubrid",
@ -13,7 +13,7 @@
} }
], ],
"statusChecker": { "statusChecker": {
"cron": "0 0/10 * * * *" "cron": "2 0/1 * * * *"
}, },
"dataSourceConfig": [ "dataSourceConfig": [
{ {
@ -21,7 +21,8 @@
"driverClassName": "oracle.jdbc.driver.OracleDriver", "driverClassName": "oracle.jdbc.driver.OracleDriver",
"url": "jdbc:oracle:thin:@mkami.foxsoft.kr:1521:xe", "url": "jdbc:oracle:thin:@mkami.foxsoft.kr:1521:xe",
"username": "ami", "username": "ami",
"password": "fox12#$%" "password": "fox12#$%",
"maximumRowForTransaction": 1000
} }
], ],
"sqlMapperLocations": [ "sqlMapperLocations": [
@ -37,7 +38,8 @@
"packages": [ "packages": [
{ {
"com.bsmlab.dfx.agent": "DEBUG", "com.bsmlab.dfx.agent": "DEBUG",
"jdbc.sqlonly": "DEBUG" "jdbc.sqlonly": "DEBUG",
"org.springframework": "INFO"
} }
] ]
}, },
@ -45,29 +47,34 @@
"receivedMessageStorageRoot": "D:/projects/bsm-lab/dfx/dfxagent/src/docs/messages/received", "receivedMessageStorageRoot": "D:/projects/bsm-lab/dfx/dfxagent/src/docs/messages/received",
"processedMessageStorageRoot": "D:/projects/bsm-lab/dfx/dfxagent/src/docs/messages/processed", "processedMessageStorageRoot": "D:/projects/bsm-lab/dfx/dfxagent/src/docs/messages/processed",
"failureMessageStorageRoot": "D:/projects/bsm-lab/dfx/dfxagent/src/docs/messages/failure", "failureMessageStorageRoot": "D:/projects/bsm-lab/dfx/dfxagent/src/docs/messages/failure",
"threadPoolSize": 300,
"retentionDaysOfProcessedMessage": 60,
"dropBoxList": [ "dropBoxList": [
] ]
}, },
"postman": [ "postmanConfig": {
{ "threadPoolSize": 30,
"postmanId": "postman-oracle-tto-bd-10", "postmanList": [
"taskType": "DB_READ_THEN_SEND", {
"action": { "postmanId": "postman-oracle-tto-bd-10",
"type": "SCHEDULED", "taskType": "DB_READ_THEN_SEND",
"cron": "0 0/1 * * * *" "action": {
}, "type": "SCHEDULED",
"message": { "cron": "0 0/1 * * * *"
"messageType": "TRANSFER_DB_TO_DB", },
"dataSourceId": "ds-oracle", "message": {
"sqlId": "address.postman.oracle.ttoBd.selectTtoBd10", "messageType": "TRANSFER_DB_TO_DB",
"postProcessingSqlId": "address.postman.oracle.ttoBd.updateTtoBd10TransferDone" "dataSourceId": "ds-oracle",
}, "sqlId": "address.postman.oracle.ttoBd.selectTtoBd10",
"recipientHostId": "bd-test-cubrid", "postProcessingSqlId": "address.postman.oracle.ttoBd.updateTtoBd10TransferDone"
"recipientDropBoxId": "db-bd-cubrid-save", },
"routingHostIdList": [ "recipientHostId": "bd-test-cubrid",
"bd-test-oracle", "recipientDropBoxId": "db-bd-cubrid-save",
"bd-test-cubrid" "routingHostIdList": [
] "bd-test-oracle",
} "bd-test-cubrid"
] ]
}
]
}
} }

57
src/docs/settings-examples/dfxagent-bd-test-oracle.json
Unescape View File

@ -11,7 +11,7 @@
} }
], ],
"statusChecker": { "statusChecker": {
"cron": "0 0/10 * * * *" "cron": "2 0/1 * * * *"
}, },
"dataSourceConfig": [ "dataSourceConfig": [
{ {
@ -19,7 +19,8 @@
"driverClassName": "oracle.jdbc.driver.OracleDriver", "driverClassName": "oracle.jdbc.driver.OracleDriver",
"url": "jdbc:oracle:thin:@mkami.foxsoft.kr:1521:xe", "url": "jdbc:oracle:thin:@mkami.foxsoft.kr:1521:xe",
"username": "ami", "username": "ami",
"password": "fox12#$%" "password": "fox12#$%",
"maximumRowForTransaction": 1000
} }
], ],
"sqlMapperLocations": [ "sqlMapperLocations": [
@ -35,7 +36,8 @@
"packages": [ "packages": [
{ {
"com.bsmlab.dfx.agent": "DEBUG", "com.bsmlab.dfx.agent": "DEBUG",
"jdbc.sqlonly": "DEBUG" "jdbc.sqlonly": "DEBUG",
"org.springframework": "INFO"
} }
] ]
}, },
@ -43,29 +45,34 @@
"receivedMessageStorageRoot": "/home/dfxagent/agent/messages/received", "receivedMessageStorageRoot": "/home/dfxagent/agent/messages/received",
"processedMessageStorageRoot": "/home/dfxagent/agent/messages/processed", "processedMessageStorageRoot": "/home/dfxagent/agent/messages/processed",
"failureMessageStorageRoot": "/home/dfxagent/agent/messages/failure", "failureMessageStorageRoot": "/home/dfxagent/agent/messages/failure",
"threadPoolSize": 300,
"retentionDaysOfProcessedMessage": 60,
"dropBoxList": [ "dropBoxList": [
] ]
}, },
"postman": [ "postmanConfig": {
{ "threadPoolSize": 30,
"postmanId": "postman-oracle-tto-bd-10", "postmanList": [
"taskType": "DB_READ_THEN_SEND", {
"action": { "postmanId": "postman-oracle-tto-bd-10",
"type": "SCHEDULED", "taskType": "DB_READ_THEN_SEND",
"cron": "0 0/1 * * * *" "action": {
}, "type": "SCHEDULED",
"message": { "cron": "0 0/1 * * * *"
"messageType": "TRANSFER_DB_TO_DB", },
"dataSourceId": "ds-oracle", "message": {
"sqlId": "address.postman.oracle.ttoBd.selectTtoBd10", "messageType": "TRANSFER_DB_TO_DB",
"postProcessingSqlId": "address.postman.oracle.ttoBd.updateTtoBd10TransferDone" "dataSourceId": "ds-oracle",
}, "sqlId": "address.postman.oracle.ttoBd.selectTtoBd10",
"recipientHostId": "bd-test-cubrid", "postProcessingSqlId": "address.postman.oracle.ttoBd.updateTtoBd10TransferDone"
"recipientDropBoxId": "db-bd-cubrid-save", },
"routingHostIdList": [ "recipientHostId": "bd-test-cubrid",
"bd-test-oracle", "recipientDropBoxId": "db-bd-cubrid-save",
"bd-test-cubrid" "routingHostIdList": [
] "bd-test-oracle",
} "bd-test-cubrid"
] ]
}
]
}
} }
Write Preview
Loading…
Cancel
Save