Azure 流分析 CreateOrReplace 转换冲突或错误请求

Posted 2023-02-19

【中文标题】Azure 流分析 CreateOrReplace 转换冲突或错误请求

【英文标题】：Azure Stream Analytics CreateOrReplace Transformation Conflict or Bad Request

【发布时间】：2017-12-23 14:33:39

【问题描述】：

我们目前正在通过 Azure 流分析将数据从 Azure 事件中心流式传输到 Cosmos DB。我希望能够以编程方式更改在数据流式传输时完成的查询（/转换）。

var existingQuery = AnalyticsClient.Transformations.Get(handler.ResourceGroup, handler.JobName, handler.JobName);

if (job.JobState == "Started")
        
            AnalyticsClient.StreamingJobs.BeginStopAsync(handler.ResourceGroup, handler.JobName).Wait();
        
        var transformation = new Transformation()
        
            Query = $@"SELECT 
                        [key] as partition_key
                    INTO[outputName]
                    FROM Input",
            StreamingUnits = 1
        ; 
AnalyticsClient.Transformations.CreateOrReplace(transformation, handler.ResourceGroup, handler.JobName, handler.JobName);

Stream Analytics Job Properties - 转换显示为空。

不清楚转换的默认名称可能是什么，但试图从作业中获取转换（与作业同名）：

    "code": "NotFound",
    "message": "StreamAnalytics_Prototype_2 does not exist in Stream Analytics job 'StreamAnalytics_Prototype_2' in resource group 'removed' in subscription 'removed'.",
    "details": 
        "code": "404",
        "message": "StreamAnalytics_Prototype_2 does not exist in Stream Analytics job 'StreamAnalytics_Prototype_2' in resource group 'removed' in subscription 'removed'.",
        "correlationId": "removed",
        "requestId": "removed"
    

尝试创建转换：

    "code": "BadRequest",
    "message": "The number of transformations defined for this job exceeds the maximum limit of 1 that is supported.",
    "details": 
        "code": "400",
        "message": "The number of transformations defined for this job exceeds the maximum limit of 1 that is supported."
    

【参考方案1】：

如果从 Azure 门户创建转换，则默认名称为转换“Transformation”。如果从 SDK 创建转换，则需要在代码中指定名称。

streamAnalyticsManagementClient.Transformations.CreateOrReplace(transformation, resourceGroupName, streamingJobName, transformationName);

顺便说一句，我在从 Azure 门户添加查询后，从 Activity 日志中找到了默认转换名称。

【讨论】：

非常感谢；这也很有用： var streamingjob = AnalyticsClient.StreamingJobs.Get(ResourceGroup, JobName, "transformation");

我还有一个 Stream 下的查询被命名为脚本（我假设开发人员通过 .net 创建了它），我能够通过活动日志中的上述方法进行检查。