Skip to content

(Piper) Node Monitor API

成文 edited this page Nov 15, 2021 · 36 revisions

1 Base API Url


[GET/POST],POST则json格式

[http:]xxxx:8617/efm.doaction?ac=action&code=action_code


2 node manage


名称 接口说明 参数说明 约束
addResource add resource socket type=SQL/NOSQL/INSTRUCTION&socket={json}
removeResource remove resource socket type=SQL&name=socketName Be care full,this will remove all relative instance
getNodeConfig get node start run configure parameters. None
setNodeConfig set node start configure parameters,will auto write into file. k=instances&v=test:1&type=set/remove
getStatus get node environmental state. None
startSearcherService open node searcher service None
stopSearcherService stop node searcher service None
startHttpReaderServiceService start node http reader pipe service None
stopHttpReaderServiceService stop node http reader pipe service None
restartNode restart node None
loadHandler Loading Java handler classes in real time None only support no dependency handler like org.elasticflow.writerUnit.handler


3 instance manage


名称 接口说明 参数说明 约束
getInstances get all instances info None
getInstanceSeqs Data source level delimited sequence instance=xxx
cloneInstance Clone one of the instances。 instance=test&new_instance_name=test_new
resetInstanceState reset Instance full and increment running state instance=xxx
reloadInstanceConfig reload instance configure,auto rebuild instance in memory instance=xx&reset=true/false reset true will recreate the instance in java from instance configure.
runNow Perform the instance task immediately instance=xx&type=full/increment
addInstance add instance into system and add to configure also. instance=xxx:1
stopInstance stop instance job instance=xxx&type=full/increment
resumeInstance resume instance job instance=xxx&type=full/increment
removeInstance remove instance stop relate jobs and save to configure file. instance=xxx
deleteInstanceData delete Instance Data through alias or Instance data name instance=xxx
getInstanceInfo get instance detail informations. instance=xxx
runCode run ElasticFlow CPU instruction program. script = script content
setInstancePipeConfig Modify task xml configuration instance=xxx&param.name=TransParam.multiThread&param.value=false