@meepeek Good questions.
- You can run swim in a cluster. Please look at this example of the transit application in a 2 node cluster: https://github.com/swimos/transit#run-as-a-fabric
- All swim lanes can be persisted if you turn the persistence option on. This is part of our enterprise offering. If you turn the persistence option on, then the data stored in the lanes for all agents of a specific type will get written into files on disk which you could then back up.
- Ideally it's best to program all the server side logic in java using the SwimOS platform
- The client can connect to the swim server directly. Web agents expose endpoints and streaming APIs, so data from the lanes will get streamed to your client
- You can configure access control and authorization programmatically. This typically done by injecting an Authenticator and a Policy to the Swim Plane. Here is an example from the cellular app: https://github.com/swimos/swim-cellular/blob/master/src/main/java/swim/cellular/CellularPlane.java#L24-L30
Please do let us know if you have any other questions. Also one question for you, how did you hear about the Swim platform?
does any example with nats.io ?
ı asked a lot question . Thanks :)
@mesh {
@part {
key: partA
predicate: @hash(0x00000000, 0x7fffffff)
@host {
#uri: "warp://localhost:9008"
primary: true
}
@host {
uri: "warp://localhost:9009"
primary: false
}
}
@part {
key: partB
predicate: @hash(0x80000000, 0xffffffff)
@host {
#uri: "warp://localhost:9008"
primary: false
}
@host {
uri: "warp://localhost:9009"
primary: true
}
}
}@mesh {
@part {
key: partA
predicate: @hash(0x00000000, 0x7fffffff)
@host {
uri: "warp://localhost:9008"
primary: true
}
@host {
#uri: "warp://localhost:9009"
primary: false
}
}
@part {
key: partB
predicate: @hash(0x80000000, 0xffffffff)
@host {
uri: "warp://localhost:9008"
primary: false
}
@host {
#uri: "warp://localhost:9009"
primary: true
}
}
}
Hi Friends,
Is there any sample code for pulling data from a SQL database. I know the ingress cookbook does allow for non-WARP protocols but it doesn't explain how to get it from database. Will it work if I change the below to use the DB connection instead?
final DataSourcePopulator pop = new DataSourcePopulator("tcp://mqtt.eclipseprojects.io:1883");
Thanks.
Great question @vinodparam . No matter your exact case, you'll need to make a query using a JDBC driver, parse the results of that query, and then relay that information (either via commands or downlinks, most likely commands) to Web Agents within a Swim server.
If the data is a one-time fetch, or something that periodically must be fetched without caring for the state within Web Agents, then it's safe to trivially do this in either the main thread, using standard JDBC drivers.
If you instead wish that the data be fetched fetched directly by Web Agents during the server's runtime (this is a fairly typical use case; for example, you may want a VehicleAgent to query a database as soon as it comes alive), then you'll have to be a little bit more careful. JDBC calls are blocking tasks, and therefore the query portion of the aforementioned query-parse-relay logic should avoid being executed in the same thread pool as the "regular" Web Agent logic. In Swim, we accomplish this by offloading the task to asyncStage(), and the http-ingress-bridges cookbook has an example of this: https://www.swimos.org/tutorials/http-ingress-bridges/
- In Java, fetch the data using standard JDBC drivers, using asyncStage() as necessary (see my precious message in this channel), and relay that data (likely with Swim commands) to your custom Web Agents
- In JavaScript, downlink to the lanes that you care about. The callback functions to the downlinks will populate the data in your view.
Thanks
Hi SwimOS Team,
Thanks for all your earlier suggestions. I was able to get the data from database and load the webagents.
The next part is plotting this on an UI. Here's one simple JS downlink I am trying to access:
var counter = 0;
const valueLink = swim.downlinkMap()
.hostUri("warp://127.0.0.1:9001")
.nodeUri("/fetchAll/vinod/sites/:siteid")
.laneUri("allSites")
.didUpdate((key, value) => {
counter++;
console.log(counter + " -> " +key + " --> " + value);
}).open();
- The JoinValueLane "allSites" has the necessary details of all the sites identified by keys /fetchAll/vinod/sites/1, /fetchAll/vinod/sites/2, etc.
- I tried setting the key on the JoinValueLane as /fetchAll/vinod/sites/ for all the entries assuming that I can listen to /fetchAll/vinod/sites/ but that didn't work out.
- If I use the nodeUri /fetchAll/vinod/sites/1, /fetchAll/vinod/sites/2 then it works fine but I cannot check for each individual siteids from UI.
I am trying to get all the sites for vinod. I feel like I am missing something here.
Any help would be appreciated.
Thanks.
@brohitbrose Doesn't the colon represent dynamic components?
This is my uri definition.
@SwimRoute("/fetchAll/:userid/sites/:siteid")
private AgentRoute<FetchAllData> idfetchUserSites;
I am able to access the data from /fetchAll/vinod/sites/1 , /fetchAll/vinod/sites/2 but I am looking for a way to access all entries in the JoinValueLane allSites, that's what I am trying with the colon.
