{"id":1468,"date":"2019-08-09T10:00:40","date_gmt":"2019-08-09T17:00:40","guid":{"rendered":"https:\/\/www.couchbase.com\/blog\/eventing-service-improvements-in-couchbase-server-6-5\/"},"modified":"2019-08-09T10:00:40","modified_gmt":"2019-08-09T17:00:40","slug":"eventing-service-improvements-in-couchbase-server-6-5","status":"publish","type":"post","link":"https:\/\/www.couchbase.com\/blog\/ko\/eventing-service-improvements-in-couchbase-server-6-5\/","title":{"rendered":"Eventing Service Improvements in Couchbase Server 6.5"},"content":{"rendered":"\n

Couchbase Eventing Service<\/a> provides a framework for writing your own functions to process data change events (create, update, delete\/expiry). Couchbase Server 6.5 introduces a set of important improvements to the Eventing Service that enable a lot of new use cases and simplify maintenance of Evening Functions.<\/p>\n\n\n\n

Source Bucket Mutations<\/h2>\n\n\n\n

An Eventing function is defined to listen to the changes of one bucket, known as the source bucket of the function. Previous versions of Couchbase did not allow a function to mutate documents in its source bucket, because if these mutations are being fed back to the function it can potentially create an infinite recursion. This limitation is removed in Couchbase 6.5: an Eventing function can now change the documents on the source bucket, even the document of the change event. Couchbase makes such changes safe by suppressing their recursive propagation to the same Eventing function.<\/p>\n\n\n\n

The possibility to change documents on the source bucket opens a lot of interesting use cases: enriching the changed documents with new attributes, performing cascade updates or deletes of dependent documents, generating new documents on the same bucket.<\/p>\n\n\n\n

The example below uses Eventing to automatically generate document attributes containing the creation time of the document and the time of its last update. We are going to listen to the changes in the travel-sample<\/strong> bucket, and generate or update the time attributes every time a document is changed. Eventing functions access buckets over so-called bucket bindings. We create a read-write bucket binding on the travel-sample<\/strong> bucket, i.e. the source bucket, and give it an alias bucket<\/strong>:<\/p>\n\n\n\n

\"\"<\/p>\n\n\n\n

In the next step provide the code of the function:<\/p>\n\n\n

[crayon toolbar-delay=”false” lang=”js” decode=”true”]function OnUpdate(doc, meta) {
\n log(‘docId’, meta.id);
\n var time = Date.now();
\n doc[“updated”] = time;
\n if (!(“created” in doc)) {
\n doc[“created”] = time;
\n }
\n log(‘newDoc’, meta, doc);
\n bucket[meta.id] = doc;
\n}
\n[\/crayon]<\/p>\n\n\n\n

In the OnUpdate<\/strong> handler, which is called on every insert and update event, we write the current time to the updated<\/strong> attribute (creating or replacing it). If the document does not yet contain created<\/strong> attribute, we assume it is the first change to the document, so we add created<\/strong> attribute containing the current time as well. After we extend the document with the new attributes we write it back to the source bucket for the same document ID.<\/p>\n\n\n\n

By changing updated<\/strong> and created<\/strong> attributes, we generate new changes to the document. Eventing framework suppresses the recursion by not propagating these changes to our function. Otherwise these changes are handled in a normal way: they are replicated, indexed and even propagated to other Eventing functions.<\/p>\n\n\n\n

Invoking External Functions with cURL<\/h2>\n\n\n\n

Eventing functions can interact with external systems by using curl<\/b> function to call their REST API. The possibility to interact with external systems opens a lot of new use cases, such as propagation of data changes to other systems, notifying the application about interesting events, enriching documents with data from external systems, and so on. A preview of the curl function was already available in earlier versions of Couchbase, but with 6.5 the feature is redesigned to make it reliable and secure: the cURL calls are limited to a predefined set of URL bindings, for each binding we can specify authentication, encryption and certificate validation as necessary.<\/p>\n\n\n\n

In the following example we will define an application listening to the changes in the travel-sample bucket. Save the application code below into file app.js<\/strong>:<\/p>\n\n\n

[crayon lang=”js” decode=”true”]const Express = require(“express”);
\nconst BasicAuth = require(“express-basic-auth”);
\nconst BodyParser = require(“body-parser”);<\/p>\n

var app = Express();
\napp.use(BodyParser.json());
\napp.use(BodyParser.urlencoded({ extended: true }));
\napp.use(BasicAuth({ users: { ‘couchbase’: ‘password’ } }))<\/p>\n

app.post(“\/api\/airline”, (request, response) => {
\n var id = request.body.id;
\n console.log(“Airline ” + id + ” changed”);
\n response.send(“OK”);
\n});<\/p>\n

var server = app.listen(3000, () => {
\n console.log(“Listening…”);
\n});[\/crayon]<\/p>\n\n\n\n

The application defines an endpoint \/api\/airline<\/strong> to receive notifications about changes of airline data as POST requests with the body containing the airline ID. The application is configured with basic authentication expecting the user couchbase<\/strong> with the password password<\/strong>.<\/p>\n\n\n\n

Execute the following commands to install the necessary node.js packages and run the application:<\/p>\n\n\n

[crayon striped=”false” nums=”false” nums-toggle=”false” lang=”sh” decode=”true”]npm init -y
\nnpm install express body-parser express-basic-auth –save
\nnode app.js
\n[\/crayon]<\/p>\n\n\n\n

Now let\u2019s create an Eventing Function that notifies our application about the changes of airline documents. All the external APIs that can be called by the function must be declared as URL bindings. Assuming the 192.168.61.1 is the IP of the machine where we started the application, we declare a URL binding for the URL https:\/\/192.168.61.1:3000\/api<\/strong> and name it notifyApi<\/b>.<\/p>\n\n\n\n

\"\"<\/p>\n\n\n\n

A URL binding can use http or https protocol. We can also specify different types of authentication, and enable cookies to avoid repeated authentication. In our case, we select basic authentication with user couchbase<\/strong> and password password<\/strong>.<\/p>\n\n\n\n

In the next step provide the code of the function, which listens to changes of the documents of type airline<\/strong> and forwards these changes to the application using curl<\/b> calls:<\/p>\n\n\n

[crayon lang=”js” decode=”true”]function OnUpdate(doc, meta) {
\n if (doc.type == ‘airline’) {
\n var request = {
\n path: ‘\/airline’,
\n body: { id : meta.id,
\n value : doc
\n }
\n };
\n log(‘request’, request);
\n var response = curl(‘POST’, notifyApi, request);
\n if (response.status != 200) {
\n log(‘request failed’, response);
\n }
\n }
\n}[\/crayon]<\/p>\n\n\n\n

The curl<\/b> function takes three parameters: the method of the HTTP request, the URL binding and the request object that can contain the following attributes:<\/p>\n\n\n\n