# Node.js Apps Import Integration

td-agent was discontinued in December 2023 and has been replaced by **fluent-package**. The fluent-package is the official successor maintained by the [Cloud Native Computing Foundation](https://www.cncf.io/projects/).

Treasure Data provides [Fluentd](/products/customer-data-platform/integration-hub/streaming/td-agent/about-treasure-data-s-server-side-agent) to collect server-side logs and events and to seamlessly import the data from Node.js applications.

The fluent-logger-node library enables Node.js applications to post records to their local Fluentd.

Fluentd, in turn, uploads the data to the cloud every 5 minutes. Because the daemon runs on a local node, the logging latency is negligible.

## Prerequisites

- Basic knowledge of Node.js and npm.
- Basic knowledge of Treasure Data.
- Node.js 22 or higher (for local testing).


## Installing Fluentd

Install Fluentd (fluent-package) on your application servers. Fluentd sits within your application servers, focusing on uploading application logs to the cloud.

![](/assets/image2020-12-2_14-6-46.1754f4e3154420d54cc976b16d454ef773c83ad5fc4b8580d99a87302c614932.7c05c672.png)

The [fluent-logger-node](https://github.com/fluent/fluent-logger-node) library enables Node.js applications to post records to their local Fluentd. Fluentd, in turn, uploads the data to the cloud every 5 minutes. Because the daemon runs on a local node, the logging latency is negligible.

## Fluentd (fluent-package) Install Options

td-agent was discontinued in December 2023 and has been replaced by **fluent-package**. The fluent-package is the official successor maintained by the [Cloud Native Computing Foundation](https://www.cncf.io/projects/). For migration guidance from td-agent, see [Fluentd Installation Guide](https://docs.fluentd.org/installation/install-fluent-package).

To install `fluent-package`, run one of the following commands based on your environment.

### RHEL/CentOS/Rocky Linux


```bash
# fluent-package 6 LTS (recommended)
curl -fsSL https://fluentd.cdn.cncf.io/sh/install-redhat-fluent-package6-lts.sh | sh
```

### Ubuntu


```bash
# Ubuntu 24.04 Noble - fluent-package 6 LTS
curl -fsSL https://fluentd.cdn.cncf.io/sh/install-ubuntu-noble-fluent-package6-lts.sh | sh

# Ubuntu 22.04 Jammy - fluent-package 6 LTS
curl -fsSL https://fluentd.cdn.cncf.io/sh/install-ubuntu-jammy-fluent-package6-lts.sh | sh
```

### Debian


```bash
# Debian Bookworm - fluent-package 6 LTS
curl -fsSL https://fluentd.cdn.cncf.io/sh/install-debian-bookworm-fluent-package6-lts.sh | sh
```

### Amazon Linux


```bash
# Amazon Linux 2023 - fluent-package 6 LTS
curl -fsSL https://fluentd.cdn.cncf.io/sh/install-amazon2023-fluent-package6-lts.sh | sh
```

### Windows

Download the MSI installer from:

- [fluent-package 6 LTS for Windows](https://fluentd.cdn.cncf.io/lts/6/windows/index.html)


After installation:

1. Edit the configuration file at `C:/opt/fluent/etc/fluent/fluentd.conf`
2. Start the service using `net start fluentdwinsvc` or via Services administrative tool


### macOS

fluent-package for macOS is planned to be available via Homebrew. For current installation options, see [Fluentd Installation Guide](https://docs.fluentd.org/installation).

## Starting the Service

After installation, start and verify the Fluentd service.

### Linux


```bash
sudo systemctl start fluentd.service
sudo systemctl status fluentd.service
```

The configuration file is located at `/etc/fluent/fluentd.conf`.

### Windows


```cmd
net start fluentdwinsvc
```

The configuration file is located at `C:\opt\fluent\etc\fluent\fluentd.conf`.

### macOS (gem installation)


```bash
fluentd -c /path/to/fluentd.conf
```

For more details, see the [Fluentd Documentation](https://docs.fluentd.org/).

## Modifying fluentd.conf

Specify your API key by setting the `apikey` option in your `/etc/fluent/fluentd.conf` file (for fluent-package). You can view your API key from your profile in Treasure Console.


```conf
# Treasure Data Input and Output
<source>
  @type forward
  port 24224
</source>

<match td.*.*>
  @type tdlog
  endpoint api.treasuredata.com
  apikey YOUR_API_KEY
  auto_create_table
  use_ssl true
  <buffer>
    @type file
    path /var/log/fluent/buffer/td
  </buffer>
</match>
```

`YOUR_API_KEY` should be your actual apikey string. You can retrieve your API key from your profiles in Treasure Console. Using a [write-only API key](/products/my-settings/getting-your-api-keys) is recommended.

Restart the Fluentd service when the following lines are in place.


```bash
# Linux
sudo systemctl restart fluentd.service

# macOS (gem installation)
# Restart the Fluentd process manually
```

Fluentd now accepts data via port 24224, buffers the data (`/var/log/fluent/buffer/td`), and automatically uploads the data into the cloud.

## Using fluent-logger-node

#### Obtaining the Most Recent Version

Obtain the most recent version of [fluent-logger-node](https://github.com/fluent/fluent-logger-node).

#### A Sample Application

A sample [Express](http://expressjs.com/) app using fluent-logger-node is as follows:

#### package.json


```
{
  "name": "node-example",
  "version": "0.0.1",
  "dependencies": {
    "express": "2.5.9",
    "fluent-logger": "0.1.0"
  }
}
```

Now use *npm* to install your dependencies locally:


```
$ npm install
fluent-logger@0.1.0 ./node_modules/fluent-logger
express@2.5.9 ./node_modules/express
|-- qs@0.4.2
|-- mime@1.2.4
|-- mkdirp@0.3.0
|-- connect@1.8.6 (formidable@1.0.9)
```

#### web.js

This is the simplest web app.


```
var express = require('express');
var app = express.createServer(express.logger());

var logger = require('fluent-logger');
logger.configure('td.test_db', {host: 'localhost', port: 24224});

app.get('/', function(request, response) {
  logger.emit('follow', {from: 'userA', to: 'userB'});
  response.send('Hello World!');
});
var port = process.env.PORT || 3000;
app.listen(port, function() {
  console.log("Listening on " + port);
});
```

## Confirming Data Import

Execute the app and go to `http://localhost:3000/` in your browser.


```bash
$ node web.js
```

Sending a SIGUSR1 signal flushes Fluentd's buffer. Upload starts immediately.


```bash
# Linux
$ kill -USR1 $(cat /var/run/fluent/fluentd.pid)

# macOS (gem installation)
# Send SIGUSR1 to the Fluentd process
```

To confirm that your data has been uploaded successfully, issue the *td tables* command as follows:


```
$ td tables
+------------+------------+------+-----------+
| Database   | Table      | Type | Count     |
+------------+------------+------+-----------+
| test_db    | follow     | log  | 1         |
+------------+------------+------+-----------+
```

|  |
|  --- |
| The first argument of post() determines the database name and table name. If you specify `td.test\_db.test\_table`, the data is imported into the table *test_table* within the database *test_db*. They are automatically created at upload time. |


## Production Deployments

### High-Availability Configurations of Fluentd

For high-traffic websites (more than 5 application nodes), use a high availability configuration of Fluentd to improve data transfer reliability and query performance.

- [High-Availability Configurations of Fluentd](/products/customer-data-platform/integration-hub/streaming/td-agent/configuring-td-agent-for-high-availability)


### Monitoring Fluentd

Monitoring Fluentd itself is also important. Refer to the following document for general monitoring methods for Fluentd.

- [Monitoring Fluentd](/products/customer-data-platform/integration-hub/streaming/td-agent/monitoring-td-agent)


Fluentd is fully open-sourced under the [Fluentd project](http://fluentd.org/).

## Next Steps

We offer a schema mechanism that is more flexible than that of traditional RDBMSs. For queries, we leverage the Hive and Trino Query Languages.

- [Schema Management](/products/customer-data-platform/data-workbench/databases/schema-management)
- [Trino Query Language](/products/customer-data-platform/data-workbench/queries/trino/writing_trino_queries)
- [Hive Query Language](/products/customer-data-platform/data-workbench/queries/hive/writing_hive_queries)
- [Programmatic Access with REST API and its Bindings](/apis/td-api)