User Profile
aswary
New Member
Joined 5 months ago
User Widgets
Contributions
Azure IotHub connection fails with Managed Private endpoint
I am trying to pull live data from Azure IotHub by following these 2 documentations for establishing connection between Fabric and Azure: - https://learn.microsoft.com/en-us/fabric/security/security-managed-private-endpoints-create - https://learn.microsoft.com/en-us/fabric/real-time-intelligence/event-streams/add-source-azure-iot-hub?pivots=enhanced-capabilities The Azure is behind a Vnet and firewall and doesn't allow public access. I have the private endpoint created and approved on IotHUB. When I try to create an eventstream and create a new connection to this IoTHub, it fails with this error: { "code":"AsaDataPreviewFailure", "message":"Unexpected status code when previewing input data. Expected Accepted or OK, but received BadRequest. Error message: {status":"ErrorConnectingToInput", "eventsDownloadUrl":null, "error":{ "code":"BadArgument", "message":"Unable to connect to IoT Hub 'azure-iot-hub' using connection string. Please make sure you have configured the IoT Hub input correctly. Exception details System.IO.IOException: Transport is closed ---> System.ObjectDisposedException: Cannot access a disposed object.Object name: 'sasl6285'. --- End of inner exception stack trace --- at Microsoft.Azure.Amqp.AsyncResult.End[TAsyncResult](IAsyncResult result) at Microsoft.Azure.Amqp.AmqpObject.OpenAsyncResult.End(IAsyncResult result) at Microsoft.Azure.Amqp.AmqpObject.EndOpen(IAsyncResult result) at Microsoft.Azure.Amqp.Transport.AmqpTransportInitiator.HandleTransportOpened(IAsyncResult result) at Microsoft.Azure.Amqp.Transport.AmqpTransportInitiator.OnTransportOpenCompete(IAsyncResult result)--- End of stack trace from previous location --- at Microsoft.Azure.Amqp.AsyncResult.End[TAsyncResult](IAsyncResult result) at Microsoft.Azure.Amqp.Transport.AmqpTransportInitiator.<>c.<ConnectAsync>b__17_1(IAsyncResult r) at System.Threading.Tasks.TaskFactory`1.FromAsyncCoreLogic(IAsyncResult iar, Func`2 endFunction, Action`1 endAction, Task`1 promise, Boolean requiresSynchronization)--- End of stack trace from previous location --- at Microsoft.Streaming.Services.TestConnectionAndSampleDataService.EventHubClient.IotHubConnection.CreateAndOpenConnectionAsync(Uri serviceEndpoint, String iotHubName, String sharedAccessKeyName, String sharedAccessKey, TimeSpan timeout) in C:__w1sProductSourceServicesTestConnectionAndSampleDataEventHubClientIotHubConnection.cs:line 196 at Microsoft.Streaming.Services.TestConnectionAndSampleDataService.EventHubClient.IotHubConnection.RequestEventHubsConnectionStringAsync(String iotHubConnectionString, Nullable`1 timeout) in C:__w1sProductSourceServicesTestConnectionAndSampleDataEventHubClientIotHubConnection.cs:line 76 at Microsoft.Streaming.Services.TestConnectionAndSampleDataService.JobAnnotationService.JobAnnotator.GetIotHubConfig(String iotHubConnectionString, String iotHubName) in C:__w1sProductSourceServicesTestConnectionAndSampleDataJobAnnotationServiceJobAnnotator.cs:line 389", "details":null}, "diagnostics":null, "lastArrivalTime":null}"} This is how I have created the IOThub connection (as suggested in the doc): and then: Error:
