Note: While adapters use a Python Framework, it’s also possible to push data from other languages like Go or JavaScript. Refer to the respective SDKs for more information:

​
Prerequisites

  • Programming Knowledge: Proficiency in Python.
  • Tools:
  • Environment Setup: Clone the trufnetwork/adapters repository.

​
Setting Up the Development Environment

  1. Clone the Repository:
git clone https://github.com/trufnetwork/adapters.git
cd adapters
  1. Configure Environment Variables:
  • Duplicate the .env.example file and rename it to .env.
  • Update the environment variables in the .env file as needed.
  1. Launch Services with Docker Compose:
docker compose up -d

This command initializes the necessary services in the background.

​
Understanding Reusable Tasks

The repository offers several reusable tasks to facilitate data ingestion into TN:

  • Reading Data:

  • task_read_repo_csv_file: Reads a CSV file from a GitHub repository.

  • task_read_gsheet: Retrieves data from a Google Sheet.

  • TN Operations:

  • task_insert_tsn_records: Inserts records into TN.

  • task_get_all_tsn_records: Fetches all records from TN.

  • task_deploy_primitive_if_needed: Deploys a primitive if it doesn’t already exist.

  • Data Manipulation:

  • task_reconcile_data: Reconciles data between sources.

  • task_normalize_source: Standardizes source data.

  • task_filter_by_source_id: Filters data based on a source ID.

  • task_prepare_records_for_tsn: Prepares records for insertion into TN.

​
Developing a Custom Adapter (Python Example)

  1. Define the Data Source: Identify the source and format of the data you intend to ingest.

  2. Create a Prefect Flow: Develop a Prefect flow to manage the data ingestion process. For example:

from prefect import flow
from tsn_adapters.tasks.github import task_read_repo_csv_file
from tsn_adapters.tasks.tsn import task_insert_tsn_records

@flow
def custom_adapter_flow():
    # Read data from the source
    data = task_read_repo_csv_file('repo_name', 'path/to/file.csv')
    # Insert data into TN
    task_insert_tsn_records('stream_id', data)
  1. Execute the Flow: Run the flow to perform the data ingestion.
python path/to/your_flow.py

​
Examples

​
Ingesting Data from Google Sheets

The repository includes examples demonstrating data ingestion from Google Sheets:

  • Direct Method: Specify the sheet ID and source ID directly.
  • Dynamic Method: Retrieve the sheet ID and source ID from a CSV file in a GitHub repository.

Refer to the examples directory for detailed implementations.

​
Additional Resources