NetSuite SuiteAnalytics Connect
This connector captures data from Oracle NetSuite into Estuary collections. It uses the SuiteAnalytics Connect feature in order to both load large amounts of data quickly, as well as introspect the available tables, their schemas, keys, and cursor fields.
ghcr.io/estuary/source-netsuite-v2:dev provides the
latest connector image. You can also follow the link in your browser to see past image versions.
In general, SuiteAnalytics Connect is the preferred method to retrieve data from NetSuite. However, if you don't have SuiteAnalytics, see the SuiteQL connector instead.
Supported data resources
Estuary discovers all of the tables to which you grant access during setup, including Transactions, Reports, Lists, and Setup.
Prerequisites
- Oracle NetSuite account
- Allowed access to all Account permissions options
- A new integration with token-based authentication
- A custom role with access to objects you want to capture. See setup.
- A new user assigned to the custom role
- Access token generated for the custom role
Setup
1. Create a NetSuite account
-
Create an account on the Oracle NetSuite portal.
-
Confirm your email address.
2. Enable SuiteAnalytics Connect
-
Navigate to Setup > Company > Enable Features.
-
Click the SuiteCloud tab.
-
In the Manage Authentication section, check the checkbox labeled TOKEN-BASED AUTHENTICATION.
-
Save your changes.
-
Next, navigate to Setup > Company > Analytics > Connectivity and check the checkbox labeled SuiteAnalytics Connect.
-
Save your changes.
3. Find Your Account ID
Find your Realm, or Account ID. You'll use this to connect with Estuary.
-
In your NetSuite portal, go to Setup > Company > Company Information.
-
Copy your Account ID.
If you have a production account, it will look like
2345678. If you're using a sandbox, it'll look like2345678_SB2.
4. Generate Consumer Tokens
Create a NetSuite integration to obtain a Consumer Key and Consumer Secret.
-
Navigate to Setup > Integration > Manage Integrations > New.
-
Give the integration a name, for example,
estuary-rest-integration. -
Make sure the State option is enabled.
-
In the Authentication section, check the Token-Based Authentication checkbox.
-
Save your changes.
Your Consumer Key and Consumer Secret will be shown once. Copy them to a safe place.
5. Set Up a Custom Role
-
Go to Setup > Users/Roles > Manage Roles > New.
-
Give the role a name, for example,
estuary-integration-role. -
Scroll to the Permissions section.
-
(IMPORTANT) Click Transactions and add all the dropdown entities with either full or view access level.
-
(IMPORTANT) Click Reports and add all the dropdown entities with either full or view access level.
-
(IMPORTANT) Click Lists and add all the dropdown entities with either full or view access level.
-
(IMPORTANT) Click Setup and add all the dropdown entities with either full or view access level.
-
(IMPORTANT) If you have multiple subsidiaries, make sure to select all of the subsidiaries you want the connector to have access to under the Role > Subsidiary Restrictions configuration.
To allow your custom role to reflect future changes, be sure to edit these parameters again when you rename or customize any NetSuite object.
6. Assign the Role to a User
-
Go to Setup > Users/Roles > Manage Users.
-
Find the user you want to give access to use with Estuary. In the Name column, click the user's name. Then, click the Edit button.
-
Find the Access tab.
-
From the dropdown list, select the role you created previously; for example,
estuary-integration-role. -
Save your changes.
7. Generate User Access Tokens
-
Go to Setup > Users/Roles > Access Tokens > New.
-
Select an Application Name.
-
Under User, select the user you assigned the role previously.
-
Under Role, select the role you assigned to the user previously.
-
Under Token Name, give a descriptive name to the token you are creating, for example
estuary-rest-integration-token. -
Save your changes.
Your Token ID and Token Secret will be shown once. Copy them to a safe place.
You now have a properly configured account with the correct permissions and all the information you need to connect with Estuary:
- Realm (Account ID)
- Consumer Key
- Consumer Secret
- Token ID
- Token Secret
You can also authenticate with a username and password, but a consumer/token is recommended for security.
Configuration
You configure connectors either in the Estuary web app, or by directly editing the catalog specification file. See connectors to learn more about using connectors. The values and specification sample below provide configuration details specific to the NetSuite source connector.
Properties
Endpoint
| Property | Title | Description | Type | Required/Default |
|---|---|---|---|---|
/account | Netsuite Account ID | Netsuite realm/Account ID e.g. 2344535, as for production or 2344535_SB1, as for sandbox | string | Required |
/suiteanalytics_data_source | Data Source | Which NetSuite data source to use. This should generally be NetSuite2.com | string | Required |
/authentication | Authentication Details | Credentials to access your NetSuite account | object | Required |
/authentication/auth_type | Authentication Type | Type of authentication used, either token or user_pass. | string | token |
Token/Consumer Authentication
| Property | Title | Description | Type | Required/Default |
|---|---|---|---|---|
/authentication/consumer_key | Consumer Key | Consumer key associated with your integration. | string | Required |
/authentication/consumer_secret | Consumer Secret | Consumer secret associated with your integration. | string | Required |
/authentication/token_id | Token ID | Access token key | string | Required |
/authentication/token_secret | Token Secret | Access token secret | string | Required |
Username/Password Authentication
| Property | Title | Description | Type | Required/Default |
|---|---|---|---|---|
/authentication/username | Username | Your NetSuite account's email/username | string | Required |
/authentication/password | Password | Your NetSuite account's password. | string | Required |
/authentication/role_id | Role ID | The ID of the role you created. Defaults to 3, which is the ID of the administrator role. | int | 3 |
Advanced Config options
| Property | Title | Description | Type | Required/Default |
|---|---|---|---|---|
/advanced/connection_limit | Connection Limit | The maximum number of concurrent data streams to attempt at once. | int | 10 Connections |
/advanced/task_limit | Task Limit | The maximum number of concurrent tasks to run at once. A task is either a backfill or incremental load. Backfills can load multiple chunks in parallel, so this must be strictly <= /advanced/connection_limit | int | 5 Tasks |
/advanced/start_date | Start Date | The date that we should attempt to start backfilling from. If not provided, backfill from the beginning. | date | Not Required |
/advanced/query_idle_timeout_seconds | Query Idle Timeout | Maximum time to wait for the next row during query execution. Query will timeout if no rows are received within this duration. | ISO8601 Duration | PT30M |
Bindings
| Property | Title | Description | Type | Required/Default |
|---|---|---|---|---|
/name | Name | The name of the table this binding refers to | string | Required |
/interval | Interval | How frequently to check for incremental changes | ISO8601 Duration | PT1H (1 Hour) |
/schedule | Schedule | Schedule to automatically rebackfill this binding. Accepts a cron expression. | string | |
/log_cursor | Log Cursor | A date-time column to use for incremental capture of modifications. | String | Required (Automatically Discovered) |
/page_cursor | Page Cursor | An indexed, non-NULL integer column to use for ordered table backfills. Does not need to be unique, but should have high cardinality. | String | Required (Automatically Discovered) |
/concurrency | Concurrency | Maximum number of concurrent connections to use for backfilling. | int | 1 Connection |
/query_limit | Query Limit | Maximum number of rows to fetch in a query. Will be divided between all connections if /concurrency > 1 | int | 100,000 Rows |
/select_columns | Manually Selected Columns | Override the columns to load from the table. If empty, all columns will be loaded. Ideally this should only be set when loading specific columns is necessary, as it won't automatically update when new columns are added or removed. | string array | [] |
/snapshot_backfill | Single-shot Backfill | Attempt to backfill using a single-shot query to load all rows. Useful when no good page cursor exists, and the table is of reasonable size. Incremental updates are still possible if a log cursor is defined. | boolean | false |
Table Associations
| Property | Title | Description | Type | Required/Default |
|---|---|---|---|---|
/associations | Associations | List of associated tables for which related data should be loaded. | Array[TableAssociation] | [] |
/associations/[n]/child_table_name | Foreign Table Name | The name of the "foreign" table that should be associated with the "parent" binding containing this association | String | Required |
/associations/[n]/parent_join_column_name | Parent Join Column | The name of the column on the "parent" table to be used as the join key | String | Required |
/associations/[n]/child_join_column_name | Foreign Join Column | The name of the column on the "foreign" table to be used as the join key | String | Required |
/associations/[n]/load_during_backfill | Load During Backfill | Whether or not to load associated documents during backfill | Boolean | False |
/associations/[n]/load_during_incremental | Load During Incremental | Whether or not to load associated documents during incremental loads | Boolean | True |
Advanced Options
| Property | Title | Description | Type | Required/Default |
|---|---|---|---|---|
/advanced | Advanced | Advanced options to customize your binding. | object | |
/advanced/initial_backfill_cursor | Initial Backfill Cursor | Manually set the starting cursor value for backfill operations. If specified, the backfill will start from this cursor value instead of the table's minimum value. Useful for partial backfills or resuming from a specific point. Only applies to the initial backfill. | int | |
/advanced/exclude_calculated | Exclude Calculated Columns | Exclude calculated columns from queries. Keys and cursors are never excluded. | boolean | false |
/advanced/exclude_custom | Exclude Custom Columns | Exclude custom columns from queries. Keys and cursors are never excluded. | boolean | false |
/advanced/exclude_hidden | Exclude Hidden Columns | Exclude hidden columns from queries. Keys and cursors are never excluded. | boolean | false |
/advanced/exclude_non_display | Exclude Non-Display Columns | Exclude non-display columns from queries. Keys and cursors are never excluded. | boolean | false |
/advanced/extra_columns | Additional Columns | Columns to include even if they match exclusion criteria. Useful for selectively re-including specific columns that would otherwise be filtered out. Cannot be used with 'Manually Selected Columns'. | string array | [] |
Sample
captures:
${PREFIX}/${CAPTURE_NAME}:
endpoint:
connector:
image: ghcr.io/estuary/source-netsuite-v2:v3
config:
account: "12345678"
authentication:
auth_type: token
consumer_key: xxx
consumer_secret_sops: xxx
token_id: xxx
token_secret_sops: xxx
suiteanalytics_data_source: NetSuite2.com
advanced:
connection_limit: 20
start_date: null
task_limit: 10
query_idle_timeout_seconds: PT30M
bindings:
- resource:
associations:
- child_join_column_name: transaction
child_table_name: TransactionAccountingLine
parent_join_column_name: id
load_during_backfill: false
load_during_incremental: true
interval: PT5M
name: transaction
page_cursor: id
query_limit: 100000
concurrency: 1
log_cursor: lastmodifieddate
select_columns: []
snapshot_backfill: false
target: ${PREFIX}/${CAPTURE_NAME}/transaction
{...}
Special Columns
NetSuite tables can include several special column types:
- Calculated Columns
- Custom Columns
- Hidden Columns
- Non-Display Columns
Ingesting these types of column can slow down queries (calculated columns, for example, require computation on every row) or cause other blockages in the data flow. Newly discovered bindings will therefore default to excluding calculated, custom, and hidden columns from your collections.
If your bindings allow special column types, newly discovered columns may impact your capture in the future, even if everything currently works as expected. It can therefore be prudent to select only the subset of NetSuite special columns you need to capture.
To set exclusions for particular special column types, configure the resource's Advanced Options.
If you find these exclusions too broad, you can add back individual filtered-out fields using the resource's Additional Columns Advanced Option.
You can find out whether a specific column falls under one of these special types in NetSuite's column metadata under the userdata field.
Setting a Schedule
Certain bindings may not be able to load data incrementally. You can instead use the schedule field for these bindings.
This allows you to specify a cron expression to rebackfill the binding.
This is helpful when performing periodic full refreshes using the paginated backfill mode. Schedules are only needed when a binding has a key and page cursor, but no log cursor.
The schedule setting should not be used in conjunction with snapshot mode.
Snapshots manage their own state and run on a schedule set by the interval field.
Attempting to backfill a snapshot using a cron schedule will cause issues with emitting deletions.