使用prefix可以指定paragraph实现多库使用在同一个解析器上

配置解析器

本质还是使用jdbc的解析器，只不过可以看到解析器里指定jdbc的连接有如下参数: default.user,default.password,default.driver,default.password，这里default就是使用缺省的连接，可以按着模式{prefix}.user,{prefix}.password,{prefix}.driver,{prefix}.password，这里prefix可以是任意自己的库相当于别名的问题，例如设置成117.user,117.url,117.driver,117.password，来指向其他的地址，

“errcode” -> {Integer@12466} 40037
“errmsg” -> “invalid template_id hint: [vcaOMA06118653]”
“data” -> {LinkedHashMap@12470} size = 2

curl –header ‘Accept: application/json’ -X POST –data “{‘config’:’{}’, ‘useDefault’:1}” http://127.0.0.1:8500/config/customer/set\?accountId\=10000009

curl –header ‘Content-Type: application/json’ –header ‘Accept: application/json’ -X POST –data “{‘config’:’{}’, ‘useDefault’:1}” http://127.0.0.1:8500/config/customer/set\?accountId\=10000019

curl –header ‘Accept: application/json’ -X GET http://127.0.0.1:8500/alert/getLast\?accountId\=100567
curl –cookie “sessionId=52f08b24-137b-4cba-b1f3-28de93d6f8bc” –header ‘Accept: application/json’ -X GET http://127.0.0.1:5559/invest-pro/alert/getLast

248

%sh echo “%html

小AI老师 - 每日调仓用户数据

“
%sh echo “%html

小AI老师 - 每日调仓用户数据

“
%sh echo “%html

小AI老师 - 每月新增自选股数据

“

org.apache.thrift.transport.TTransportException
at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429)
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318)
at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
at org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService$Client.recv_angularRegistryPush(RemoteInterpreterService.java:688)
at org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService$Client.angularRegistryPush(RemoteInterpreterService.java:675)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.pushAngularObjectRegistryToRemote(RemoteInterpreter.java:441)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.access$100(RemoteInterpreter.java:58)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter$1.call(RemoteInterpreter.java:148)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter$1.call(RemoteInterpreter.java:139)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreterProcess.callRemoteFunction(RemoteInterpreterProcess.java:135)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.open(RemoteInterpreter.java:139)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getFormType(RemoteInterpreter.java:299)
at org.apache.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:407)
at org.apache.zeppelin.scheduler.Job.run(Job.java:188)
at org.apache.zeppelin.scheduler.RemoteScheduler$JobRunner.run(RemoteScheduler.java:315)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
org.apache.thrift.transport.TTransportException
at org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429)
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318)
at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
at org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService$Client.recv_angularRegistryPush(RemoteInterpreterService.java:688)
at org.apache.zeppelin.interpreter.thrift.RemoteInterpreterService$Client.angularRegistryPush(RemoteInterpreterService.java:675)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.pushAngularObjectRegistryToRemote(RemoteInterpreter.java:441)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.access$100(RemoteInterpreter.java:58)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter$1.call(RemoteInterpreter.java:148)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter$1.call(RemoteInterpreter.java:139)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreterProcess.callRemoteFunction(RemoteInterpreterProcess.java:135)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.open(RemoteInterpreter.java:139)
at org.apache.zeppelin.interpreter.remote.RemoteInterpreter.getFormType(RemoteInterpreter.java:299)
at org.apache.zeppelin.notebook.Paragraph.jobRun(Paragraph.java:407)
at org.apache.zeppelin.scheduler.Job.run(Job.java:188)
at org.apache.zeppelin.scheduler.RemoteScheduler$JobRunner.run(RemoteScheduler.java:315)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)