Copytorethink

flowtask.components.CopyToRethink

CopyToRethink

CopyToRethink(loop=None, job=None, stat=None, **kwargs)

Bases: CopyTo, PandasDataframe

CopyToRethink.

Overview

This component allows copy data into a RethinkDB table,
Copy into main rethinkdb using write functionality.

.. table:: Properties :widths: auto

+--------------+----------+-----------+--------------------------------------------+ | Name | Required | Summary | +--------------+----------+-----------+--------------------------------------------+ | tablename | Yes | Name of the table in | | | | the database | +--------------+----------+-----------+--------------------------------------------+ | schema | Yes | Name of the schema | | | | where is to the table, alias: database | +--------------+----------+-----------+--------------------------------------------+ | truncate | Yes | This option indicates if the component should empty | | | | before coping the new data to the table. If set to true| | | | the table will be truncated before saving the new data.| +--------------+----------+-----------+--------------------------------------------+ | use_buffer | No | When activated, this option allows optimizing the | | | | performance of the task, when dealing with large | | | | volumes of data. | +--------------+----------+-----------+--------------------------------------------+ | credentials | No | Supporting manual rethinkdb credentials | | | | | +--------------+----------+-----------+--------------------------------------------+ | datasource | No | Using a Datasource instead manual credentials | | | | | +--------------+----------+-----------+--------------------------------------------+

Example:

```yaml
CopyToRethink:
  tablename: product_availability
  schema: bose
```

default_connection

default_connection()

default_connection.

Default Connection to RethinkDB.