Data & Integration Nodes
Data and integration nodes handle the core plumbing of your workflows -- making API calls, querying databases, reading and writing files, transforming data, and connecting to cloud services.
Core Data Nodes
The seven foundational nodes for data processing and integration.
Make HTTP/HTTPS requests to any API. Supports GET, POST, PUT, PATCH, DELETE with headers, query params, body (JSON, form, raw), authentication (Bearer, Basic, API Key, OAuth2), and response parsing.
Execute SQL queries against PostgreSQL or MySQL databases. Supports parameterized queries, transactions, and result mapping. Connect using stored credentials.
Read and write files on the local filesystem. All file operations are sandboxed to a secure directory for security. Supports text, binary, CSV, and JSON formats.
Transform JSON data using expressions, mapping rules, or JSONata queries. Reshape, filter, and restructure data between nodes.
Combine data from multiple upstream branches into a single output. Supports append, merge by key, inner join, outer join, and zip modes.
Create or modify variables in the workflow data. Set static values, compute expressions, rename fields, or transform data types.
Call tools exposed via the Model Context Protocol (MCP). Connect to any MCP-compatible server and invoke its tools with typed inputs and outputs.
HTTP Request Details
The HTTP Request node is the most versatile integration node. It can call any REST API, GraphQL endpoint, or webhook URL.
| Setting | Description |
|---|---|
| Method | GET, POST, PUT, PATCH, DELETE, HEAD, OPTIONS |
| URL | Full URL with optional expression interpolation |
| Authentication | None, Bearer Token, Basic Auth, API Key (header/query), OAuth2 |
| Headers | Custom request headers as key-value pairs |
| Body | JSON, form-data, x-www-form-urlencoded, raw text, or binary |
| Response | Auto-parsed JSON, raw text, or binary. Configurable error handling for non-2xx status codes. |
// Example: Call an API with dynamic parameters
Method: POST
URL: https://api.example.com/users/{{ $json.userId }}/orders
Headers:
Authorization: Bearer {{ $credentials.apiToken }}
Content-Type: application/json
Body:
{
"product": "{{ $json.productName }}",
"quantity": {{ $json.qty }}
}Database SQL Details
Execute SQL queries against relational databases. Always use parameterized queries to prevent SQL injection.
| Feature | Description |
|---|---|
| Supported Databases | PostgreSQL, MySQL |
| Parameterized Queries | Use $1, $2, ... placeholders with a parameters array |
| Transactions | Wrap multiple queries in a single transaction |
| Result Mapping | Rows are returned as JSON arrays accessible via expressions |
SQL injection prevention
$1, $2) instead of string concatenation. NodeLoom does not allow raw expression interpolation inside SQL query strings.File Operations
The File node reads and writes files within a sandboxed directory. This prevents workflows from accessing sensitive system files.
Sandbox restriction
Merge Modes
The Merge node supports several strategies for combining data from multiple branches:
| Mode | Behavior |
|---|---|
| Append | Concatenate all items from all branches into a single array |
| Merge by Key | Match items across branches by a shared key field and combine their properties |
| Inner Join | Only include items that have a matching key in all branches |
| Outer Join | Include all items from all branches, filling missing fields with null |
| Zip | Pair items by index position across branches |
Cloud Services
Dedicated nodes for interacting with cloud infrastructure and managed services.
Upload, download, list, copy, and delete objects in Amazon S3 buckets. Supports presigned URLs and multipart uploads.
Invoke AWS Lambda functions synchronously or asynchronously. Pass input payloads and receive function responses.
Send messages to and receive messages from Amazon SQS queues. Supports standard and FIFO queues.
Upload, download, list, and delete objects in Google Cloud Storage buckets.
Publish messages to Google Cloud Pub/Sub topics. Configure message attributes and ordering keys.
Query, insert, update, and delete documents in MongoDB collections. Supports aggregation pipelines and bulk operations.
Execute Redis commands -- GET, SET, HGET, HSET, LPUSH, RPOP, and more. Configure key expiration and data serialization.
MCP Tool
The MCP Tool node connects to servers implementing the Model Context Protocol. MCP provides a standardized way for AI applications to access tools, data sources, and prompts. Configure the MCP server URL and select which tool to invoke. Input and output schemas are automatically discovered from the server.
Use with AI Agent