Embedded Integration
Platform
Your customers ask for integrations.
Meet their needs without sacrificing on your own product
Embedded Integration
Platform
Your customers ask for integrations.
Meet their needs without sacrificing on your own product
Power up your product with embedded integration
FULL CUSTOMIZATION
Keep it all under your brand: UI, support and users docs, and more
CLOUD-NATIVE
Ensure the continuous exchange of data with no risk of downtime
STANDARDIZATION
Easily create your own connectors for third-party apps & custom APIs
EMBED OR WHITE-LABEL
Flows, integrations and users can be created directly via iPaaS API
FULL SUPPORT AND SLA
Enterprise-grade SLA and 2nd level support are included
sdk
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
const request = require ('request-promise');
/**
* This method will be called from elastic.io with following parameteers
*
* @param msg incoming message object that contains ``body`` with payload
* @param cfg configuration that is account information and configuration field values
*/
async function process (msg, cfg) {
console.log ('You stdout will be safe with us');
const user = await request.get (`https://api.github.com/users/${msg.body.user}?length=${cfg.pageSize}`);
const repos = await request.get (user.repos_url);
console.log (`Fetched ${repos.length} repos`);
return { repos };
}
module.exports.process = process;
public class CreateCustomerAction implements Module {
private static final Logger logger = LoggerFactory.getLogger(CreateCustomerAction
.class) ;
@Override
public final void execute (ExecutionParameters parameters) {
// This is an incoming message
final Message message = parameters.getMessage() ;
logger.info("Received message {}", message) ;
// This is outgoing result
final JsonObject body = Json.createObjectBuilder()
.add("message", "hello world")
.build() ;
final Message data = new Message.Builder().body(body).build() ;
// Sending it to the next integration step
parameters.getEventEmitter().emitData(data) ;
}
}
Coming soon.
integration management api
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
curl https://api.elastic.io/v2/flows \
-u {EMAIL}:{APIKEY} \
-H 'Accept: application/json' \
-H 'Content-Type: application/json' -d '
{
"data": {
"type": "flow",
"attributes": {
"name": "Timer to E-Mail",
"type": "ordinary",
"graph": {
"nodes": [
{
"id": "step_1",
"command": "elasticio/timer:timer",
"fields": {
"interval": "minute"
}
},
{
"id": "step_2",
"command": "elasticio/email:send"
}
],
"edges": [
{
"source": "step_1",
"target": "step_2",
"config": {
"mapper": {
"to": "info@acme.org",
"subject": "Test",
"textBody": "{{fireTime}}"
}
}
}
]
}
}
}
}'
curl https://api.elastic.io/v2/users \
-X POST \
-u {EMAIL}:{APIKEY} \
-H 'Accept: application/json' \
-H 'Content-Type: application/json' -d '
{
"data": {
"type": "user",
"attributes": {
"first_name": "John",
"last_name": "Doe",
"email": "test@example.com",
"password": "secret",
"company": "Doe & Partners"
},
"relationships": {
"organizations": {
"data": [
{"id": "54f4be3fe7d5224f91000001"}
]
}
}
}
}'
curl https://api.elastic.io/v2/flows/{FLOW_ID}/start \
-X POST \
-u {EMAIL}:{APIKEY} \
-H 'Accept: application/json' \
-H 'Content-Type: application/json'