Using this extension a MongoDB Event Table can be configured to persist events in a MongoDB of user's choice.
Using this extension a MongoDB Event Table can be configured to persist events in a MongoDB of user's choice.
Using this extension a MongoDB Event Table can be configured to persist events in a MongoDB of user's choice.
+ +Syntax + +``` +@Store(type="mongodb", mongodb.uri="| Name | +Description | +Default Value | +Possible Data Types | +Optional | +Dynamic | +
|---|---|---|---|---|---|
| mongodb.uri | +The MongoDB URI for the MongoDB data store. The uri must be of the format |
+ + | STRING | +No | +No | +
| collection.name | +The name of the collection in the store this Event Table should be persisted as. |
+ Name of the siddhi event table. | +STRING | +Yes | +No | +
| secure.connection | +Describes enabling the SSL for the mongodb connection |
+ false | +STRING | +Yes | +No | +
| trust.store | +File path to the trust store. |
+ ${carbon.home}/resources/security/client-truststore.jks | +STRING | +Yes | +No | +
| trust.store.password | +Password to access the trust store |
+ wso2carbon | +STRING | +Yes | +No | +
| key.store | +File path to the keystore. |
+ ${carbon.home}/resources/security/client-truststore.jks | +STRING | +Yes | +No | +
| key.store.password | +Password to access the keystore |
+ wso2carbon | +STRING | +Yes | +No | +
| Name | +Description | +Default Value | +Possible Parameters | +
|---|---|---|---|
| applicationName | +Sets the logical name of the application using this MongoClient. The application name may be used by the client to identify the application to the server, for use in server logs, slow query logs, and profile collection. |
+ null | +the logical name of the application using this MongoClient. The UTF-8 encoding may not exceed 128 bytes. | +
| cursorFinalizerEnabled | +Sets whether cursor finalizers are enabled. |
+ true | +true false |
+
| requiredReplicaSetName | +The name of the replica set |
+ null | +the logical name of the replica set | +
| sslEnabled | +Sets whether to initiate connection with TSL/SSL enabled. true: Initiate the connection with TLS/SSL. false: Initiate the connection without TLS/SSL. |
+ false | +true false |
+
| trustStore | +File path to the trust store. |
+ ${carbon.home}/resources/security/client-truststore.jks | +Any valid file path. | +
| trustStorePassword | +Password to access the trust store |
+ wso2carbon | +Any valid password. | +
| keyStore | +File path to the keystore. |
+ ${carbon.home}/resources/security/client-truststore.jks | +Any valid file path. | +
| keyStorePassword | +Password to access the keystore |
+ wso2carbon | +Any valid password. | +
| connectTimeout | +The time in milliseconds to attempt a connection before timing out. |
+ 10000 | +Any positive integer | +
| connectionsPerHost | +The maximum number of connections in the connection pool. |
+ 100 | +Any positive integer | +
| minConnectionsPerHost | +The minimum number of connections in the connection pool. |
+ 0 | +Any natural number | +
| maxConnectionIdleTime | +The maximum number of milliseconds that a connection can remain idle in the pool before being removed and closed. A zero value indicates no limit to the idle time. A pooled connection that has exceeded its idle time will be closed and replaced when necessary by a new connection. |
+ 0 | +Any positive integer | +
| maxWaitTime | +The maximum wait time in milliseconds that a thread may wait for a connection to become available. A value of 0 means that it will not wait. A negative value means to wait indefinitely |
+ 120000 | +Any integer | +
| threadsAllowedToBlockForConnectionMultiplier | +The maximum number of connections allowed per host for this MongoClient instance. Those connections will be kept in a pool when idle. Once the pool is exhausted, any operation requiring a connection will block waiting for an available connection. |
+ 100 | +Any natural number | +
| maxConnectionLifeTime | +The maximum life time of a pooled connection. A zero value indicates no limit to the life time. A pooled connection that has exceeded its life time will be closed and replaced when necessary by a new connection. |
+ 0 | +Any positive integer | +
| socketKeepAlive | +Sets whether to keep a connection alive through firewalls |
+ false | +true false |
+
| socketTimeout | +The time in milliseconds to attempt a send or receive on a socket before the attempt times out. Default 0 means never to timeout. |
+ 0 | +Any natural integer | +
| writeConcern | +The write concern to use. |
+ acknowledged | +acknowledged w1 w2 w3 unacknowledged fsynced journaled replica_acknowledged normal safe majority fsync_safe journal_safe replicas_safe |
+
| readConcern | +The level of isolation for the reads from replica sets. |
+ default | +local majority linearizable |
+
| readPreference | +Specifies the replica set read preference for the connection. |
+ primary | +primary secondary secondarypreferred primarypreferred nearest |
+
| localThreshold | +The size (in milliseconds) of the latency window for selecting among multiple suitable MongoDB instances. |
+ 15 | +Any natural number | +
| serverSelectionTimeout | +Specifies how long (in milliseconds) to block for server selection before throwing an exception. A value of 0 means that it will timeout immediately if no server is available. A negative value means to wait indefinitely. |
+ 30000 | +Any integer | +
| heartbeatSocketTimeout | +The socket timeout for connections used for the cluster heartbeat. A value of 0 means that it will timeout immediately if no cluster member is available. A negative value means to wait indefinitely. |
+ 20000 | +Any integer | +
| heartbeatConnectTimeout | +The connect timeout for connections used for the cluster heartbeat. A value of 0 means that it will timeout immediately if no cluster member is available. A negative value means to wait indefinitely. |
+ 20000 | +Any integer | +
| heartbeatFrequency | +Specify the interval (in milliseconds) between checks, counted from the end of the previous check until the beginning of the next one. |
+ 10000 | +Any positive integer | +
| minHeartbeatFrequency | +Sets the minimum heartbeat frequency. In the event that the driver has to frequently re-check a server's availability, it will wait at least this long since the previous check to avoid wasted effort. |
+ 500 | +Any positive integer | +
This will create a collection called FooTable for the events to be saved with symbol as Primary Key(unique index at mongod level) and index for the field volume will be created in ascending order with the index option to create the index in the background.
Note:
@PrimaryKey: This specifies a list of comma-separated values to be treated as unique fields in the table. Each record in the table must have a unique combination of values for the fields specified here.
@IndexBy: This specifies the fields that must be indexed at the database level. You can specify multiple values as a come-separated list. A single value to be in the format,
“<FieldName> <SortOrder> <IndexOptions>”
<SortOrder> - ( 1) for Ascending and (-1) for Descending
<IndexOptions> - Index Options must be defined inside curly brackets. {} to be used for default options. Options must follow the standard mongodb index options format. Reference : https://docs.mongodb.com/manual/reference/method/db.collection.createIndex/
Example : “symbol 1 {“unique”:true}”
Using this extension a MongoDB Event Table can be configured to persist events in a MongoDB of user's choice.
+## Store +### mongodb *(Store)* + +Using this extension a MongoDB Event Table can be configured to persist events in a MongoDB of user's choice.
+ Syntax + ``` @Store(type="mongodb", mongodb.uri="The MongoDB URI for the MongoDB data store. The uri must be of the format
mongodb://[username:password@]host1[:port1][,hostN[:portN]][/[database][?options]]
The options specified in the uri will override any connection options specified in the deployment yaml file.
The name of the collection in the store this Event Table should be persisted as.
Describes enabling the SSL for the mongodb connection
File path to the trust store.
Password to access the trust store
File path to the keystore.
Password to access the keystore
Sets the logical name of the application using this MongoClient. The application name may be used by the client to identify the application to the server, for use in server logs, slow query logs, and profile collection.
Sets whether cursor finalizers are enabled.
The name of the replica set
Sets whether to initiate connection with TSL/SSL enabled. true: Initiate the connection with TLS/SSL. false: Initiate the connection without TLS/SSL.
File path to the trust store.
Password to access the trust store
File path to the keystore.
Password to access the keystore
The time in milliseconds to attempt a connection before timing out.
The maximum number of connections in the connection pool.
The minimum number of connections in the connection pool.
The maximum number of milliseconds that a connection can remain idle in the pool before being removed and closed. A zero value indicates no limit to the idle time. A pooled connection that has exceeded its idle time will be closed and replaced when necessary by a new connection.
The maximum wait time in milliseconds that a thread may wait for a connection to become available. A value of 0 means that it will not wait. A negative value means to wait indefinitely
The maximum number of connections allowed per host for this MongoClient instance. Those connections will be kept in a pool when idle. Once the pool is exhausted, any operation requiring a connection will block waiting for an available connection.
The maximum life time of a pooled connection. A zero value indicates no limit to the life time. A pooled connection that has exceeded its life time will be closed and replaced when necessary by a new connection.
Sets whether to keep a connection alive through firewalls
The time in milliseconds to attempt a send or receive on a socket before the attempt times out. Default 0 means never to timeout.
The write concern to use.
The level of isolation for the reads from replica sets.
Specifies the replica set read preference for the connection.
The size (in milliseconds) of the latency window for selecting among multiple suitable MongoDB instances.
Specifies how long (in milliseconds) to block for server selection before throwing an exception. A value of 0 means that it will timeout immediately if no server is available. A negative value means to wait indefinitely.
The socket timeout for connections used for the cluster heartbeat. A value of 0 means that it will timeout immediately if no cluster member is available. A negative value means to wait indefinitely.
The connect timeout for connections used for the cluster heartbeat. A value of 0 means that it will timeout immediately if no cluster member is available. A negative value means to wait indefinitely.
Specify the interval (in milliseconds) between checks, counted from the end of the previous check until the beginning of the next one.
Sets the minimum heartbeat frequency. In the event that the driver has to frequently re-check a server's availability, it will wait at least this long since the previous check to avoid wasted effort.
This will create a collection called FooTable for the events to be saved with symbol as Primary Key(unique index at mongod level) and index for the field volume will be created in ascending order with the index option to create the index in the background.
Note:
@PrimaryKey: This specifies a list of comma-separated values to be treated as unique fields in the table. Each record in the table must have a unique combination of values for the fields specified here.
@IndexBy: This specifies the fields that must be indexed at the database level. You can specify multiple values as a come-separated list. A single value to be in the format,
“<FieldName> <SortOrder> <IndexOptions>”
<SortOrder> - ( 1) for Ascending and (-1) for Descending
<IndexOptions> - Index Options must be defined inside curly brackets. {} to be used for default options. Options must follow the standard mongodb index options format. Reference : https://docs.mongodb.com/manual/reference/method/db.collection.createIndex/
Example : “symbol 1 {“unique”:true}”
This will create a collection called FooTable for the events to be saved with symbol as Primary Key(unique index at mongod level) and index for the field volume will be created in ascending order with the index option to create the index in the background.
Note:
@PrimaryKey: This specifies a list of comma-separated values to be treated as unique fields in the table. Each record in the table must have a unique combination of values for the fields specified here.
@IndexBy: This specifies the fields that must be indexed at the database level. You can specify multiple values as a come-separated list. A single value to be in the format,
“<FieldName> <SortOrder> <IndexOptions>”
<SortOrder> - ( 1) for Ascending and (-1) for Descending
<IndexOptions> - Index Options must be defined inside curly brackets. {} to be used for default options. Options must follow the standard mongodb index options format. Reference : https://docs.mongodb.com/manual/reference/method/db.collection.createIndex/
Example : “symbol 1 {“unique”:true}”
Using this extension a MongoDB Event Table can be configured to persist events in a MongoDB of user's choice.
Using this extension a MongoDB Event Table can be configured to persist events in a MongoDB of user's choice.