Beta
Ultimate

Stream Snowflake data to Experience Platform using the Flow Service API

IMPORTANT
  • The Snowflake streaming source is in beta. Please read the Sources overview for more information on using beta-labeled sources.
  • The Snowflake streaming source is available in the API to users who have purchased Real-Time Customer Data Platform Ultimate.

This tutorial provides steps on how to connect and stream data from your Snowflake account to Adobe Experience Platform using the Flow Service API.

Getting started

This guide requires a working understanding of the following components of Adobe Experience Platform:

  • Sources: Experience Platform allows data to be ingested from various sources while providing you with the ability to structure, label, and enhance incoming data using Platform services.
  • Sandboxes: Experience Platform provides virtual sandboxes which partition a single Platform instance into separate virtual environments to help develop and evolve digital experience applications.

For prerequisite set up and information on the Snowflake streaming source. Please read the Snowflake streaming source overview.

Using Platform APIs

For information on how to successfully make calls to Platform APIs, see the guide on getting started with Platform APIs.

Create a base connection create-a-base-connection

A base connection retains information between your source and Platform, including your source’s authentication credentials, the current state of the connection, and your unique base connection ID. The base connection ID allows you to explore and navigate files from within your source and identify the specific items that you want to ingest, including information regarding their data types and formats.

To create a base connection ID, make a POST request to the /connections endpoint while providing your Snowflake authentication credentials as part of the request body.

API format

POST /connections

Request

The following request creates a base connection for Snowflake:

TIP
The auth.specName value must be inputted exactly as the example below, including the blank spaces.
curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/connections' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "name": "Snowflake base connection",
      "description": "Snowflake base connection",
      "auth": {
          "specName": "Basic Authentication for Snowflake",
          "params": {
              "account": "wixnnnd-ui60793.snowflakecomputing.com",
              "database": "ACME_DB",
              "warehouse": "ACME_WH",
              "username": "nikola15",
              "schema": "PUBLIC",
              "password": "xxxx",
              "role": "ACCOUNTADMIN"
          }
      },
      "connectionSpec": {
          "id": "51ae16c2-bdad-42fd-9fce-8d5dfddaf140",
          "version": "1.0"
      }
  }'
Property
Description
auth.params.account
The name of your Snowflake streaming account.
auth.params.database
The name of your Snowflake database where data will be pulled from.
auth.params.warehouse
The name of your Snowflake warehouse. The Snowflake warehouse manages the query execution process for the application. Each warehouse is independent from one another and must be accessed individually when bringing data over to Platform.
auth.params.username
The username for your Snowflake streaming account.
auth.params.schema
(Optional) The database schema associated with your Snowflake streaming account.
auth.params.password
The password for your Snowflake streaming account.
auth.params.role
(Optional) The role of the user for this Snowflake connection. If unprovided, this value defaults to public.
connectionSpec.id
The Snowflake connection specification ID: 51ae16c2-bdad-42fd-9fce-8d5dfddaf140.

Response

A successful response returns the newly created base connection and its corresponding etag.


{
    "id": "1b614dc0-b76e-41e1-b25f-09f4a9d3f111",
    "etag": "\"d300cf4e-0000-0200-0000-6447a7750000\""
}

Explore your data tables explore-your-data-tables

Next, use the base connection ID to explore and navigate through your source’s data tables by making a GET request to the /connections/{BASE_CONNECTION_ID}/explore?objectType=root endpoint while providing your base connection ID as a parameter.

API format

GET /connections/{BASE_CONNECTION_ID}/explore?objectType=root
Parameter
Description
{BASE_CONNECTION_ID}
The base connection ID of your Snowflake streaming source.

Request

The following request retrieves the structure and contents of your Snowflake streaming account.

curl -X GET \
  'https://platform.adobe.io/data/foundation/flowservice/connections/1b614dc0-b76e-41e1-b25f-09f4a9d3f111/explore?objectType=root' \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}'

Response

A successful response returns the structure and contents of your source’s data at the root-level.

{
    "items": [
        {
            "type": "table",
            "name": "ACME"
        }
    ]
}
Property
Description
items.type
The type of the table.
items.names
The name of the table.

Create a source connection create-a-source-connection

A source connection creates and manages the connection to the external source from where data is ingested.

To create a source connection, make a POST request to the /sourceConnections endpoint of the Flow Service API.

API format

POST /sourceConnections

Request

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/sourceConnections' \
  -H 'authorization: Bearer {ACCESS_TOKEN}' \
  -H 'content-type: application/json' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -d '{
      "name": "Snowflake Streaming Source Connection",
      "description": "A source connection for Snowflake Streaming data",
      "baseConnectionId": "1b614dc0-b76e-41e1-b25f-09f4a9d3f111",
      "connectionSpec": {
          "id": "51ae16c2-bdad-42fd-9fce-8d5dfddaf140",
          "version": "1.0"
      },
      "params": {
          "tableName": "ACME",
          "timestampColumn": "dOb",
          "backfill": "true",
          "timezoneValue": "PST"
      }
  }'
Property
Description
baseConnectionId
The authenticated base connection ID for your Snowflake streaming source. This ID was generated in an earlier step.
connectionSpec.id
The connection spec ID for the Snowflake streaming source.
params.tableName
The name of the table in your Snowflake database that you want to bring to Platform.
params.timestampColumn
The name of the timestamp column that will be used to fetch incremental values.
params.backfill
A boolean flag that determines whether data is fetched from the beginning (0 epoch time) or from the time the source is initiated. For more information on this value, read the Snowflake streaming source overview.
params.timezoneValue
The timezone value indicates which timezone’s current time should be fetched when querying the Snowflake database. This parameter should be provided if the timestamp column in the config is set to TIMESTAMP_NTZ. If unprovided, timezoneValue defaults to UTC.

Response

A successful response returns your source connection ID and its corresponding etag. The source connection ID will be used in a later step to create a dataflow.


{
    "id": "61c0c5f1-bfe5-40f7-8f8c-a4dc175ddac6",
    "etag": "\"d300cf4e-0000-0200-0000-6447a7750000\""
}

Create a dataflow

To create a dataflow to stream data from tour Snowflake account to Platform, you must make a POST request to the /flows endpoint while providing the following values:

TIP
Follow the links below for step-by-step guides on how to retrieve the following IDs.

API format

POST /flows

Request

The following request creates a streaming dataflow for your Snowflake account.

curl -X POST \
  'https://platform.adobe.io/data/foundation/flowservice/flows' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {ORG_ID}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -H 'Content-Type: application/json' \
  -d '{
      "name": "Snowflake Streaming Dataflow",
      "description": "A dataflow for Snowflake streaming data",
      "sourceConnectionIds": [
        "61c0c5f1-bfe5-40f7-8f8c-a4dc175ddac6"
      ],
      "targetConnectionIds": [
        "78f41c31-3652-4a5e-b264-74331226dcf3"
      ],
      "flowSpec": {
        "id": "c1a19761-d2c7-4702-b9fa-fe91f0613e81",
        "version": "1.0"
      },
      "transformations": [
        {
          "name": "Mapping",
          "params": {
            "mappingId": "44d42ed27c46499a80eb0c0705c38cbd",
            "mappingVersion": 0
          }
        }
      ]
    }'
Property
Description
sourceConnectionIds
The source connection ID for your Snowflake streaming source.
targetConnectionIds
The target connection ID for your Snowflake streaming source.
flowSpec.id
The flow spec ID to create a dataflow for a Snowflake streaming source. This flow spec ID allows you to create a streaming dataflow with mapping transformations. This ID is fixed and is: c1a19761-d2c7-4702-b9fa-fe91f0613e81.
transformations.params.mappingId
The mapping ID for your dataflow.

Response

A successful response returns your flow ID and its corresponding etag.

{
    "id": "2edc08ac-4df5-4fe6-936f-81a19ce92f5c",
    "etag": "\"770029f8-0000-0200-0000-6019e7d40000\""
}

Next steps

By following this tutorial, you have created a streaming dataflow for your Snowflake data using the Flow Service API. Visit the following documentation for additional information on Adobe Experience Platform Sources:

recommendation-more-help
337b99bb-92fb-42ae-b6b7-c7042161d089