Use this REST request to upsert a record into an ESP window. This REST request is a POST type request.
http://serverDetails/espws/restservice/stream/<stream/window name>?action=upsert&workspace=<workspaceName>&project=<projectName>
Element | Description |
---|---|
connectionDetails |
(Required) Element containing cluster, port, and authentication details below. |
clusterName |
Type: string (Required) The name of the cluster on which the project that you wish to update is running. |
port |
Type: integer (Required) Specify the port on which the cluster is running. |
authentication |
(Required) Element containing authentication details. |
type |
Type: string (Required) Specify the type of authentication the ESP Server is using. Valid values are user, rsa, and kerberos. |
data |
Type: string (Required) Specify a value based on the type of authentication
you specified in the type element. For
example,
|
sslEnabled |
Type: boolean (Required) Specify whether SSL is enabled on the cluster on which the project is running. The default value is false. |
Element | Description |
---|---|
content |
(Required) Element containing content details for the REST request. |
<primaryKey> |
(Required for windows only) Specify the window's PRIMARY KEY and a unique value. The format is "<primarykeyname>":<uniquevalue>. For example, "pKey":"1". If you do not specify a unique value, the request returns an error unless you are performing an update. The PRIMARY KEY is specified in the CCL of the project. |
<columnname> |
(Optional) Specify a column to which you wish to publish data. The format is "<columnname>":"<value>". For example, "amount":"10". If a column is specified in the request content but does not exist in the stream or window schema, the column is ignored. If you do not specify existing column schema in the request content, these columns are filled with a NULL value by default. |
http://<server>:<port>/espws/restservice/stream/InputWindow1?action=upsert&workspace=<workspaceName>&project=<projectName>Body
{ "connectionDetails": { "clusterName":"<cluster name>", "port":"<port>", "authentication": { "type":"user", "data":"<username>:<password>", "sslEnabled":"false" } }, "content": { "C_KEY":"5", "C_TIMESTAMP":"1992-06-06 00:00:00.000" } }