Supply Software
Supply via SlapOS Panel
Login to the panel and click on Servers (c).
Select the machine on which you want to supply Fluentd.
Click on the Supply button.

Select Fluentd.

Choose the newest version.

Click on Proceed.
Wait until the compilation process has been finished.
Supply via SlapOS Client
First find the reference of your Streaming Device.
It is located in your Slapos Dashboard in Servers tab.
Then using supply command of Slapos Client install Fluentd software release on that computer.
supply("https://lab.nexedi.com/nexedi/slapos/raw/master/software/fluentd/software.cfg", "YOUR_COMPUTER_ID")
Configuration Parameters
<source>
@type exec
tag YOUR_TAG_NAME
command python3 /usr/local/bin/custom_read_bme280.py
run_interval 1m
<parse>
keys pressure, humidity, temperature
</parse>
</source>
<match YOUR_TAG_NAME>
@type forward
<server>
name myserver1
host IPV6_ADDRESS_OF_YOUR_IOT_GATEWAY
</server>
</match>
About Fluentd configuration file you can learn from here.
For input plugin we use Fluentd's standard exec plugin.
The plugin will execute the python script we wrote in HowTo Setup Sensor and IOT Gateway to read sensor data every minute.
For output plugin we use Fluentd's standard forward plugin.
YOUR_TAG_NAME - it must consist of two part separated by .(dot). For example sensor_1.sample-environment-raw-data. First part (sensor_1) is the name of the sensor and must be the same as the reference of the Data Supply we created in HowTo Create Data Supply tutorial. The second part (sample-environment-raw-data) is the type of data (Data Product - HowTo Create Data Product).
host - IPV6 address of your server where data will be send. In our case it will be the address of IOT Gateway.
Request Instance
Request via SlapOS Panel
Go to the SlapOS dashboard and click on the Services (l) button.

Click on the add button.

Select Fluentd.

Pick the newest version.
Select the machine on which you previously supplied Fluentd by clicking on the Computer Node drop-down list. This is the machine on which the instance will be requested.

Enter a title for your Fluentd instance

Fill in the Fluentd configuration parameters in the Instance Parameter field. You can use the <parameter> tag to specify certain parameters of your instance. The name for the Fluentd configuration parameter is conf_text. Because the Instance Parameter itself is written in XML we have to escape our Fluentd Configuration File. You can use an Online XML escape tool (for instance appdevtools).
The escaped form of the configuration would be something similar to:
<?xml version="1.0" encoding="utf-8" ?><instance>
<parameter id="conf_text"><source>
@type exec
tag YOUR_TAG_NAME
command python3 /usr/local/bin/custom_read_bme280.py
run_interval 1m
<parse>
keys pressure, humidity, temperature
</parse>
</source>
<match YOUR_TAG_NAME>
@type forward
<server>
name myserver1
host IPV6_ADDRESS_OF_YOUR_IOT_GATEWAY
</server>
</match>
</parameter>
</instance>
Don't forget to correctly fill in your computer reference, Instance name, url etc.
Finally click Proceed to request the instance.
Request via SlapOS Client
config_params = """<source>
@type exec
tag YOUR_TAG_NAME
command python3 /usr/local/bin/custom_read_bme280.py
run_interval 1m
<parse>
keys pressure, humidity, temperature
</parse>
</source>
<match YOUR_TAG_NAME>
@type forward
<server>
name myserver1
host IPV6_ADDRESS_OF_YOUR_IOT_GATEWAY
</server>
</match>"""
request("https://lab.nexedi.com/nexedi/slapos/raw/master/software/fluentd/software.cfg", "Sensor-Tutorial-Fluentd",filter_kw={"computer_guid": "YOUR_COMPUTER_ID"}, partition_parameter_kw={"conf_text":config_params})
As the Fluentd configuration has many parameters for convenience we will write a short python script which will request the instance, instead of calling request function from Slapos Client.
Create a python script and name it request_fluentd.py and copy/paste the presented code.
** Don't forget to correctly fill in your computer reference, Instance name, url etc.
As we are requesting instance of fluentd for the same computer the reference is the same as when we were supplying the software.
"YOUR_INSTANCE_NAME" - give your instance a distinguishing name so you can later easily find it. For example Sensor-Tutorial-Fluentd.
Once it's ready run it by calling following command :
slapos console request_fluentd.py
Monitor instantiation
You can monitor the process by running
tail -f /opt/slapos/log/slapos-node-instance.log
on the respective machine.