Re: Σχετ: Σχετ: DRPC http request
Without looking at your setup I really don't know. - Bobby On Saturday, December 17, 2016 3:46 AM, "tsantalos-spa...@yahoo.gr.INVALID"wrote: Thank you for your help. It seems that the problem is somewhere else as i have tried all possible urls. In fact, if i simply run the ManualDRCP strom example and then hit the url, nothing works... I suppose i should make some other configurations?? Στις 10:56 μ.μ. Παρασκευή, 16 Δεκεμβρίου 2016, ο/η Bobby Evans έγραψε: "exclamation" is the function, not "exclaim" the url should be http://localhost:3774/drpc/exclamation/aaa "exclaim; is the name of your topology, not the name of the function. - Bobby On Friday, December 16, 2016 2:52 PM, "tsantalos-spa...@yahoo.gr.INVALID" wrote: Ok, for the following typical storm example, how am I supposed to send a request over http ?? I see that via calling drpc.execute("exclamation", "aaa") you send the request aaa. The corresponding url over http?? The http://localhost:3774/drpc/exclaim/aaa does not work TopologyBuilder builder = new TopologyBuilder(); LocalDRPC drpc = new LocalDRPC(); LocalCluster cluster = new LocalCluster(); DRPCSpout spout = new DRPCSpout("exclamation", drpc); builder.setSpout("drpc", spout); builder.setBolt("exclaim", new ExclamationBolt(), 3).shuffleGrouping("drpc"); builder.setBolt("return", new ReturnResults(), 3).shuffleGrouping("exclaim"); Config conf = new Config(); cluster.submitTopology("exclaim", conf, builder.createTopology()) ; System.out.println(drpc.execute("exclamation", "aaa")); Thank you in advance. Στις 6:58 μ.μ. Παρασκευή, 16 Δεκεμβρίου 2016, ο/η Bobby Evans έγραψε: By default the http port for DRPC is 3774. DRPC also requires a function and a payload. Your topology that is using DRPC should have been configured with a function to use. I don't know what that function is but you should know because you have launched your own topology. If you have configured and launched a DRPC server on localhost and the function your are using is test, and you want to send a payload of payload to the topology, then you could do something like curl http://localhost:3774/drpc/test/payload If your payload is too large/complex to include in a URL, then you can POST your payload to http://localhost:3774/drpc/test - Bobby On Friday, December 16, 2016 9:48 AM, kalliopi kalantzaki wrote: Hello, I am confused probably by something quite trivial for most drpc users. I have implemented an initial Drpc storm project. My questions are: 1) If a third party wants to post an http request to my drcp application, how is this possible? I have found that this is made according to http://drpc_server:drpc_http_port/drpc/app/request_to_post. However, this does not work... I have configured my drpc server as localhost, according to default configurations on storm. 2) If this is possible in storm, how can i get this value (the request_to_post value) in my application? I haven't found any documentation on that...
Σχετ: Σχετ: DRPC http request
Thank you for your help. It seems that the problem is somewhere else as i have tried all possible urls. In fact, if i simply run the ManualDRCP strom example and then hit the url, nothing works... I suppose i should make some other configurations?? Στις 10:56 μ.μ. Παρασκευή, 16 Δεκεμβρίου 2016, ο/η Bobby Evansέγραψε: "exclamation" is the function, not "exclaim" the url should be http://localhost:3774/drpc/exclamation/aaa "exclaim; is the name of your topology, not the name of the function. - Bobby On Friday, December 16, 2016 2:52 PM, "tsantalos-spa...@yahoo.gr.INVALID" wrote: Ok, for the following typical storm example, how am I supposed to send a request over http ?? I see that via calling drpc.execute("exclamation", "aaa") you send the request aaa. The corresponding url over http?? The http://localhost:3774/drpc/exclaim/aaa does not work TopologyBuilder builder = new TopologyBuilder(); LocalDRPC drpc = new LocalDRPC(); LocalCluster cluster = new LocalCluster(); DRPCSpout spout = new DRPCSpout("exclamation", drpc); builder.setSpout("drpc", spout); builder.setBolt("exclaim", new ExclamationBolt(), 3).shuffleGrouping("drpc"); builder.setBolt("return", new ReturnResults(), 3).shuffleGrouping("exclaim"); Config conf = new Config(); cluster.submitTopology("exclaim", conf, builder.createTopology()) ; System.out.println(drpc.execute("exclamation", "aaa")); Thank you in advance. Στις 6:58 μ.μ. Παρασκευή, 16 Δεκεμβρίου 2016, ο/η Bobby Evans έγραψε: By default the http port for DRPC is 3774. DRPC also requires a function and a payload. Your topology that is using DRPC should have been configured with a function to use. I don't know what that function is but you should know because you have launched your own topology. If you have configured and launched a DRPC server on localhost and the function your are using is test, and you want to send a payload of payload to the topology, then you could do something like curl http://localhost:3774/drpc/test/payload If your payload is too large/complex to include in a URL, then you can POST your payload to http://localhost:3774/drpc/test - Bobby On Friday, December 16, 2016 9:48 AM, kalliopi kalantzaki wrote: Hello, I am confused probably by something quite trivial for most drpc users. I have implemented an initial Drpc storm project. My questions are: 1) If a third party wants to post an http request to my drcp application, how is this possible? I have found that this is made according to http://drpc_server:drpc_http_port/drpc/app/request_to_post. However, this does not work... I have configured my drpc server as localhost, according to default configurations on storm. 2) If this is possible in storm, how can i get this value (the request_to_post value) in my application? I haven't found any documentation on that...
Re: Σχετ: DRPC http request
"exclamation" is the function, not "exclaim" the url should be http://localhost:3774/drpc/exclamation/aaa "exclaim; is the name of your topology, not the name of the function. - Bobby On Friday, December 16, 2016 2:52 PM, "tsantalos-spa...@yahoo.gr.INVALID"wrote: Ok, for the following typical storm example, how am I supposed to send a request over http ?? I see that via calling drpc.execute("exclamation", "aaa") you send the request aaa. The corresponding url over http?? The http://localhost:3774/drpc/exclaim/aaa does not work TopologyBuilder builder = new TopologyBuilder(); LocalDRPC drpc = new LocalDRPC(); LocalCluster cluster = new LocalCluster(); DRPCSpout spout = new DRPCSpout("exclamation", drpc); builder.setSpout("drpc", spout); builder.setBolt("exclaim", new ExclamationBolt(), 3).shuffleGrouping("drpc"); builder.setBolt("return", new ReturnResults(), 3).shuffleGrouping("exclaim"); Config conf = new Config(); cluster.submitTopology("exclaim", conf, builder.createTopology()) ; System.out.println(drpc.execute("exclamation", "aaa")); Thank you in advance. Στις 6:58 μ.μ. Παρασκευή, 16 Δεκεμβρίου 2016, ο/η Bobby Evans έγραψε: By default the http port for DRPC is 3774. DRPC also requires a function and a payload. Your topology that is using DRPC should have been configured with a function to use. I don't know what that function is but you should know because you have launched your own topology. If you have configured and launched a DRPC server on localhost and the function your are using is test, and you want to send a payload of payload to the topology, then you could do something like curl http://localhost:3774/drpc/test/payload If your payload is too large/complex to include in a URL, then you can POST your payload to http://localhost:3774/drpc/test - Bobby On Friday, December 16, 2016 9:48 AM, kalliopi kalantzaki wrote: Hello, I am confused probably by something quite trivial for most drpc users. I have implemented an initial Drpc storm project. My questions are: 1) If a third party wants to post an http request to my drcp application, how is this possible? I have found that this is made according to http://drpc_server:drpc_http_port/drpc/app/request_to_post. However, this does not work... I have configured my drpc server as localhost, according to default configurations on storm. 2) If this is possible in storm, how can i get this value (the request_to_post value) in my application? I haven't found any documentation on that...
Σχετ: DRPC http request
Ok, for the following typical storm example, how am I supposed to send a request over http ?? I see that via calling drpc.execute("exclamation", "aaa") you send the request aaa. The corresponding url over http?? The http://localhost:3774/drpc/exclaim/aaa does not work TopologyBuilder builder = new TopologyBuilder(); LocalDRPC drpc = new LocalDRPC(); LocalCluster cluster = new LocalCluster(); DRPCSpout spout = new DRPCSpout("exclamation", drpc); builder.setSpout("drpc", spout); builder.setBolt("exclaim", new ExclamationBolt(), 3).shuffleGrouping("drpc"); builder.setBolt("return", new ReturnResults(), 3).shuffleGrouping("exclaim"); Config conf = new Config(); cluster.submitTopology("exclaim", conf, builder.createTopology()) ; System.out.println(drpc.execute("exclamation", "aaa")); Thank you in advance. Στις 6:58 μ.μ. Παρασκευή, 16 Δεκεμβρίου 2016, ο/η Bobby Evansέγραψε: By default the http port for DRPC is 3774. DRPC also requires a function and a payload. Your topology that is using DRPC should have been configured with a function to use. I don't know what that function is but you should know because you have launched your own topology. If you have configured and launched a DRPC server on localhost and the function your are using is test, and you want to send a payload of payload to the topology, then you could do something like curl http://localhost:3774/drpc/test/payload If your payload is too large/complex to include in a URL, then you can POST your payload to http://localhost:3774/drpc/test - Bobby On Friday, December 16, 2016 9:48 AM, kalliopi kalantzaki wrote: Hello, I am confused probably by something quite trivial for most drpc users. I have implemented an initial Drpc storm project. My questions are: 1) If a third party wants to post an http request to my drcp application, how is this possible? I have found that this is made according to http://drpc_server:drpc_http_port/drpc/app/request_to_post. However, this does not work... I have configured my drpc server as localhost, according to default configurations on storm. 2) If this is possible in storm, how can i get this value (the request_to_post value) in my application? I haven't found any documentation on that...