Power Platform Community Forum Thread Details

Hello Poweruser Community,

I am using Azure Data Explorer within flow, however am receiving a 400 bad request when connecting to Azure Data Explorer. For reference, I have used Run Query and List Results(preview) step within the Send email on a recurring basis if Azure Kusto query returns results template.

I have verified connection and that query returns results from: https://dataexplorer.azure.com/
in order to narrow down the issue to the connector.

Below is the telemetry associated with the bad request:
Headers

Pragma

no-cache

x-ms-request-id

ac203ac9-fee9-4fdd-85fb-baeeb60e05e8

Strict-Transport-Security

max-age=31536000; includeSubDomains

X-Content-Type-Options

nosniff

X-Frame-Options

DENY

Timing-Allow-Origin

x-ms-apihub-cached-response

true

Cache-Control

no-store, no-cache

Date

Fri, 13 Mar 2020 00:39:35 GMT

Set-Cookie

ARRAffinity=c0c0e2cbf160983fb14d8f38467064b10673a9e32c4b8ae701adc9d95cb6deba;Path=/;HttpOnly;Domain=kusto-wcus.azconn-wcus-01.p.azurewebsites.net

Content-Length

7850

Content-Type

application/json

Expires

-1

Body

{

"ClassName": "Kusto.Data.Exceptions.SemanticException",

"Message": "clientRequestId: ac203ac9-fee9-4fdd-85fb-baeeb60e05e8",

"Data": null,

"InnerException": null,

"HelpURL": null,

"StackTraceString": " at Kusto.Cloud.Platform.Http.KustoHttpClient.<ThrowKustoExceptionFromResponseMessageAsync>d__4.MoveNext()\r\n--- End of stack trace from previous location where exception was thrown ---\r\n at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()\r\n at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)\r\n at Kusto.Data.Net.Client.RestClient2.<MakeHttpRequestAsyncImpl>d__40.MoveNext()\r\n--- End of stack trace from previous location where exception was thrown ---\r\n at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()\r\n at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)\r\n at Kusto.Cloud.Platform.Utils.MonitoredActivity.<InvokeAsync>d__15`2.MoveNext()\r\n--- End of stack trace from previous location where exception was thrown ---\r\n at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()\r\n at Kusto.Cloud.Platform.Utils.MonitoredActivity.<InvokeAsync>d__15`2.MoveNext()\r\n--- End of stack trace from previous location where exception was thrown ---\r\n at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()\r\n at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)\r\n at Kusto.Data.Net.Client.RestClient2.<MakeHttpRequestAsync>d__38.MoveNext()\r\n--- End of stack trace from previous location where exception was thrown ---\r\n at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()\r\n at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)\r\n at Kusto.Data.Net.Client.RestClient2.<ExecuteQueryAsync>d__27.MoveNext()\r\n--- End of stack trace from previous location where exception was thrown ---\r\n at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()\r\n at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)\r\n at Microsoft.Azure.Connectors.KustoConnector.Controllers.KustoController.<ForwardRequestToKustoAsync>d__27.MoveNext() in X:\\bt\\1026498\\repo\\src\\source\\SAAS\\Kusto\\Controllers\\KustoController.cs:line 369",

"RemoteStackTraceString": null,

"RemoteStackIndex": 0,

"ExceptionMethod": "8\nMoveNext\nKusto.Data, Version=6.1.8.0, Culture=neutral, PublicKeyToken=829a00acde12d551\nKusto.Cloud.Platform.Http.KustoHttpClient+<ThrowKustoExceptionFromResponseMessageAsync>d__4\nVoid MoveNext()",

"HResult": -2146233088,

"Source": "Kusto.Data",

"WatsonBuckets": null,

"creationMessage": null,

"creationContext": {

"Timestamp": "2020-03-13T00:39:36.1354884Z",

"ServiceAlias": "",

"MachineName": "RD00155D063F24",

"ProcessName": "w3wp",

"ProcessId": 9204,

"ThreadId": 25972,

"AppDomainName": "/LM/W3SVC/296980501/ROOT-1-132282821686374824",

"ActivityContext": {

"ActivityId": "18b42e0f-cb48-4eb1-9622-56af5f5bc262",

"SubActivityId": "18b42e0f-cb48-4eb1-9622-56af5f5bc262",

"ParentActivityId": "18b42e0f-cb48-4eb1-9622-56af5f5bc262",

"ClientRequestId": "ac203ac9-fee9-4fdd-85fb-baeeb60e05e8",

"ActivityType": "DN-RestClient-ExecuteControlCommand"

"ActivityStack": "(Activity stack: CRID=ac203ac9-fee9-4fdd-85fb-baeeb60e05e8 ARID=18b42e0f-cb48-4eb1-9622-56af5f5bc262 > DN-RestClient-ExecuteControlCommand/18b42e0f-cb48-4eb1-9622-56af5f5bc262)",

"TracingContext": null,

"MonitoredActivityContext": {

"Created": "2020-03-13T00:39:35.3854432Z",

"Activity": {

"ActivityId": "18b42e0f-cb48-4eb1-9622-56af5f5bc262",

"SubActivityId": "18b42e0f-cb48-4eb1-9622-56af5f5bc262",

"ParentActivityId": "18b42e0f-cb48-4eb1-9622-56af5f5bc262",

"ClientRequestId": "ac203ac9-fee9-4fdd-85fb-baeeb60e05e8",

"ActivityType": "DN-RestClient-ExecuteControlCommand"

}

"TestContext": null

"ErrorCode": "SEM0001",

"ErrorReason": "BadRequest",

"ErrorMessage": "Ensure that expression: deploymentPayload.[\"DeploymentRequestAction\"] is indeed a simple name",

"DataSource": "https://clixprod.kusto.windows.net/v1/rest/query",

"DatabaseName": "ClxProd",

"ClientRequestId": "ac203ac9-fee9-4fdd-85fb-baeeb60e05e8",

"ActivityId": "ed09b29b-627a-48cd-9761-18f79fccd9b4",

"Text": "let migrationDetails = ClxStateEvents \n| where (message contains 'DeploymentServiceDBMigrationWorkflow') and TIMESTAMP between (datetime(2020-01-27) .. datetime(2020-01-29))\n| extend eploymentPayload = parsejson(payload) \n| extend RequestAction = tostring(deploymentPayload[\"DeploymentRequestAction\"]) \n| extend deploymentPayload = parsejson(payload) \n| extend TopologyName = tostring(deploymentPayload[\"TopologyName\"]) \n| extend RequestAction = tostring(deploymentPayload[\"DeploymentRequestAction\"]) \n| extend EnvironmentId = tostring(deploymentPayload[\"EnvironmentId\"]) \n| extend EnvironmentName = tostring(deploymentPayload[\"EnvironmentName\"]) \n| extend DataCenter = tostring(deploymentPayload[\"DataCenter\"]) \n| extend SubscriptionId = tostring(deploymentPayload[\"AzureSubscription\"]) \n| extend ExecutionTime = round(todouble(duration)/60, 2) \n| extend TenantId = tostring(deploymentPayload[\"TenantId\"]) \n| extend ProjectId = tolong(strcat(\"0x\",substring(TenantId, 2, 6))) \n| extend EnvironmentDetails = strcat(\"https://lcs.dynamics.com/V2/EnvironmentDetailsV3New/\",ProjectId,\"?EnvironmentId=\",EnvironmentId) \n| extend ApplicationVersion = strcat(tostring(deploymentPayload[\"ApplicationVersion\"]),\" [\",tostring(deploymentPayload[\"AX7Version\"]),\"] - \",tostring(deploymentPayload[\"AX7Branch\"])) \n| extend TopologySkuType = tostring(deploymentPayload[\"TopologySkuType\"]) \n| project startTime, endTime, ExecutionTime,PreciseTimeStamp,ActivityId, ProjectId,EnvironmentId,EnvironmentName,stateStatus,EnvironmentDetails,SubscriptionId,TenantId,ApplicationVersion,TopologySkuType,DataCenter,TopologyName, payload; \nlet activityids = migrationDetails | distinct ActivityId; \nlet request = ClxExecutionEvents \n| where ActivityId in (activityids) \n| where component == \"DeploymentServiceEngine\" and message contains \"Attempting to Migrate the [[\" \n| distinct ActivityId, message \n| project ActivityId, DatabaseTypes = message; \nlet result = ClxExecutionEvents \n| where ActivityId in (activityids) \n| where component == \"DeploymentServiceEngine\" and message contains \"returned status of\" \n| distinct ActivityId, message \n| project ActivityId, MigrationResult = message; \nmigrationDetails \n| join kind = leftouter (request) on $left.ActivityId == $right.ActivityId \n| join kind = leftouter (result) on $left.ActivityId == $right.ActivityId \n| extend DatabaseTypes = trim_end(\"\\\\]\\\\] Database to Elastic Pool\", trim_start(\"Attempting to Migrate the \\\\[\\\\[\", DatabaseTypes))\n| extend MigrationState = trim_end(\"\\\\]\",trim_start(\"State \\\\[\",extract(\"State \\\\[([A-Za-z0-9]+?)\\\\]\",0,MigrationResult))) \n| extend MigrationStatus = trim_end(\"\\\\]\",trim_start(\"Staus \\\\[\",extract(\"Staus \\\\[([A-Za-z0-9]+?)\\\\]\",0,MigrationResult))) \n| project \nActivityId, \nProjectId, \nEnvironmentName, \nDatabaseTypes, \nstateStatus, \nMigrationState, \nMigrationStatus, \nEnvironmentId, \nTenantId, \nSubscriptionId, \nstartTime, \nendTime, \nExecutionTime, \nPreciseTimeStamp, \nEnvironmentDetails, \nApplicationVersion, \nTopologySkuType, \nDataCenter, \nTopologyName, \npayload;",

"SemanticErrors": "Ensure that expression: deploymentPayload.[\"DeploymentRequestAction\"] is indeed a simple name"

}

Categories:

Using connectors