Atlas Stream Processing supports creating Private Link connections to Azure Blob Storage.
Select an option to display the procedure to add the connection using your preferred interface:
Add an Azure Private Link Connection through the Atlas Administration API
To add an Azure Blob Storage Private Link connection to your stream processing workspace through the Atlas Administration API, perform these steps:
Set up Azure Service Principal Access.
Follow the procedure described in Set Up and Manage Azure Service Principal Access.
Grant your Service Principal the following permissions:
Storage Blob Data Contributorfor your storage accountStorage Blob Data Contributorfor your blob storage containersReaderpermissions for the Azure Subscription containing both the storage account and blob containers.
Note the Service Principal ID you used for later in this procedure.
Enable Atlas IP Access to Azure.
The Atlas Administration API provides an endpoint to Return All Control Plane IP Addresses.
Note the values of the IP addresses in the outbound.aws.us-east-1 field of the response.
Configure your Azure Storage Account to permit access to as described in the network security page of the Azure Blob Storage documentation, providing the IP addresses, stripped of CIDR notation, that you noted earlier.
Create your Azure private endpoint.
Perform the procedure outlined on the Create a private endpoint page of the Azure documentation. Note the service endpoint ID for later in this procedure.
In Atlas, go to the Users page.
If it's not already displayed, select your desired organization from the Organizations menu in the navigation bar.
Click All Projects in the sidebar under the Identity & Access section, and select your desired project.
Click Project Identity & Access in the sidebar under the Security section.
The Users page displays.
Configure a Service Account.
Create a service account.
Grant this service account the following roles within your Atlas Stream Processing project:
Create the Private Link endpoint.
The Atlas Administration API provides an endpoint to Create One Private Link.
For an Azure Blob Storage Private Link connection, set the following key-value pairs:
Key | Value |
|---|---|
|
|
|
|
| The Azure region in which you create the endpoint. |
| The service endpoint ID you noticed earlier. |
| The name of the Azure Storage Account to which you want to connect. |
Use Return All Private Link Connections to check the state of your endpoint. When it reaches a DONE state, note the value of the _id field.
Connect your stream processor to the Azure Private Link endpoint.
The Atlas Administration API provides an endpoint to Create One Stream Connection.
For an Azure Blob Storage Private Link connection, set the following key-value pairs:
Key | Value |
|---|---|
| Name you want to give to the connection. |
| The region in which you create the connection. Atlas Stream Processing supports Azure Private Link connections only in the same region as their respective endpoints. |
| "AzureBlobStorage" |
|
|
| Name of the Azure Storage Account to which to connect. |
| "PRIVATE_LINK" |
| Value of |
Add an Azure Private Link Connection through the Atlas CLI
To add an Azure Blob Storage Private Link connection to your stream processing workspace through the Atlas CLI, perform these steps:
Set up Azure Service Principal Access.
Follow the procedure described in Set Up and Manage Azure Service Principal Access.
Grant your Service Principal the following permissions:
Storage Blob Data Contributorfor your storage accountStorage Blob Data Contributorfor your blob storage containersReaderpermissions for the Azure Subscription containing both the storage account and blob containers.
Note the Service Principal ID you used for later in this procedure.
Enable Atlas IP Access to Azure
Retrieve your Atlas control plane IP addresses.
Note the values of the IP addresses in the outbound.aws.us-east-1 field of the response.
Configure your Azure Storage Account to permit access to as described in the network security page of the Azure Blob Storage documentation, providing the IP addresses, stripped of CIDR notation, that you noted earlier.
Create your Azure private endpoint.
Perform the procedure outlined on the Create a private endpoint page of the Azure documentation. Note the service endpoint ID for later in this procedure.
In Atlas, go to the Users page.
If it's not already displayed, select your desired organization from the Organizations menu in the navigation bar.
Click All Projects in the sidebar under the Identity & Access section, and select your desired project.
Click Project Identity & Access in the sidebar under the Security section.
The Users page displays.
Configure a Service Account
Create a service account.
Grant this service account the following roles within your Atlas Stream Processing project:
Create the Private Link endpoint.
To a Private Link endpoint for a stream processor connection using the Atlas CLI, run the following command:
atlas streams privateLinks create [options]
To learn more about the command syntax and parameters, see the Atlas CLI documentation for atlas streams privateLinks create.
In your configuration file, set the following key-value pairs:
Key | Value |
|---|---|
|
|
|
|
| The Azure region in which you create the endpoint. |
| The service endpoint ID you noticed earlier. |
| The name of the Azure Storage Account to which you want to connect. |
Use the atlas streams privateLinks list command to check the state of your endpoint. When it reaches a DONE state, note the value of the _id field.
Connect your stream processor to the Azure Private Link endpoint.
To create one connection for the stream processing workspace you specify using the Atlas CLI, run the following command:
atlas streams connections create [connectionName] [options]
To learn more about the command syntax and parameters, see the Atlas CLI documentation for atlas streams connections create.
In your configuration file, set the following key-value pairs:
Key | Value |
|---|---|
| Name you want to give to the connection. |
| The region in which you create the connection. Atlas Stream Processing supports Azure Private Link connections only in the same region as their respective endpoints. |
| "AzureBlobStorage" |
|
|
| Name of the Azure Storage Account to which to connect. |
| "PRIVATE_LINK" |
| Value of |
Add an Azure Private Link Connection through the Atlas UI
To add an Azure Blob Storage Private Link connection to your stream processing workspace through the Atlas UI, perform these steps:
Set up Azure Service Principal Access.
Follow the procedure described in Set Up and Manage Azure Service Principal Access.
Grant your Service Principal the following permissions:
Storage Blob Data Contributorfor your storage accountStorage Blob Data Contributorfor your blob storage containersReaderpermissions for the Azure Subscription containing both the storage account and blob containers.
Note the Service Principal ID you used for later in this procedure.
Enable Atlas IP Access to Azure.
The Atlas Administration API provides an endpoint to Return All Control Plane IP Addresses.
Note the values of the IP addresses in the outbound.aws.us-east-1 field of the response.
Configure your Azure Storage Account to permit access to as described in the network security page of the Azure Blob Storage documentation, providing the IP addresses, stripped of CIDR notation, that you noted earlier.
Create your Azure private endpoint.
Perform the procedure outlined on the Create a private endpoint page of the Azure documentation. Note the service endpoint ID for later in this procedure.
In Atlas, go to the Users page.
If it's not already displayed, select your desired organization from the Organizations menu in the navigation bar.
Click All Projects in the sidebar under the Identity & Access section, and select your desired project.
Click Project Identity & Access in the sidebar under the Security section.
The Users page displays.
Create the Private Link endpoint.
Set Cloud Provider to Azure.
Set Vendor to Blob Storage.
Click Next, enter service details
Provide the Azure service endpoint ID you noted earlier.
Provide the Endpoint region in which you created the endpoint. Atlas Stream Processing supports Azure Private Link connections only in the same region as their respective endpoints.
Provide the Host name of the Azure Storage Account to which you want to connect.
Click Next, generate endpoint ID
In Atlas, go to the Stream Processing page for your project.
If it's not already displayed, select the organization that contains your project from the Organizations menu in the navigation bar.
If it's not already displayed, select your project from the Projects menu in the navigation bar.
In the sidebar, click Stream Processing under the Streaming Data heading.
The Stream Processing page displays.
Connect your stream processor to the Azure Private Link endpoint.
Click + Add connection.
Select an Azure Blob Storage connection.
Provide a Connection Name. Each connection name must be unique within a stream processing workspace. This is the name used to reference the connection in Atlas Stream Processing aggregations.
Click the Private Link button.
Toggle Enable Private Link Networking on.
From the dropdown menu, select the private endpoint you created earlier.
From the Azure Service Principal dropdown, select the service principal defined earlier in this procedure.
Provide the Storage Account Name for the Azure Storage Account to which you want to connect.
Click + Add Connection.
Supported Aggregation Behavior
Azure Blob Storage sink connections support only the $emit stage, not the $merge stage. For more information, see $emit.