Azure Stream Analytics作业启动报查询编译错误，测试查询正常

你遇到的是ASA里典型的「静态测试与流式作业行为不一致」的问题——上传文件测试时查询能正常返回结果，但启动流式作业却报错。核心原因是批处理测试模式和流式处理模式对数组访问的语法要求不同，流式作业的查询编译规则更严格，不支持直接嵌套GetArrayElement并访问其内部属性的写法。

问题根源 #

在ASA的流式处理模式中，像GetArrayElement(message.Body.NewRx.MedicationPrescribed, 0).CompoundInformation.FinalCompoundPharmaceuticalDosageForm这种直接嵌套访问数组元素属性的写法是不被支持的，哪怕静态测试（批处理模式）允许这种操作。流式查询要求必须通过CROSS APPLY或OUTER APPLY来展开数组，再访问元素属性。

解决方案：改用CROSS APPLY展开数组 #

我们需要修改查询，用CROSS APPLY（适用于数组非空的场景）或OUTER APPLY（适用于数组可能为空、不想过滤主记录的场景）展开目标数组，再通过别名访问元素属性。如果只需要数组的第一个元素，可以结合TOP 1来获取。

以下是修改后的完整查询：

SELECT 
    message.Header.MessageID src_msg_id,
    prescriberSPI as msg_pbr_spi,
    eventProducedTime as evt_produce_dttm,
    correlationId as correlation_id,
    transactionType as msg_txn_type,
    message.Header.RelatesToMessageID as relate_to_msg_id,
    message.Header.SentTime as msg_sent_dttm,
    message.Header.SenderSoftware.SenderSoftwareDeveloper as sndr_software_developer_name,
    message.Header.SenderSoftware.SenderSoftwareProduct as sndr_software_prod__name,
    message.Header.SenderSoftware.SenderSoftwareVersionRelease as sndr_software_vers_release,
    message.Header.RxReferenceNumber.encValue as rx_ref_nbr,
    message.Header.PrescriberOrderNumber as pbr_ord_nbr,
    message.Header.DigitalSignature.DigitalSignatureIndicator as dgtl_signature_ind,
    message.Header.DigitalSignature.DigestMethod as dgtl_signature_digest_method,
    message.Header.PrescriberOrderGroup.OrderGroupNumber as ord_group_nbr,
    message.Header.PrescriberOrderGroup.ItemCountInOrderGroup as item_cnt_in_ord_group,
    message.Header.PrescriberOrderGroup.TotalCountForOrderGroup as tot_cnt_for_ord_group,
    message.Header.PrescriberOrderGroup.OrderGroupReason as ord_group_reason,
    message.Body.NewRx.UrgencyIndicatorCode as urgency_cd,
    message.Body.NewRx.ChangeOfPrescriptionStatusFlag as rx_stat_chng_cd,
    message.Body.NewRx.FollowUpRequest as followup_reqst_nbr,
    message.Body.NewRx.AllergyOrAdverseEvent.NoKnownAllergies as allergy_no_known_ind,
    -- 从展开的MedicationPrescribed数组中取第一个元素的属性
    mp.CompoundInformation.FinalCompoundPharmaceuticalDosageForm as fnl_cmpnd_dosage_form_cd,
    -- 从展开的Observation数组中取第一个元素的属性
    obs.ObservationNotes as observation_note
FROM blobinput
-- 展开MedicationPrescribed数组，仅保留第一个元素
CROSS APPLY (
    SELECT TOP 1 * 
    FROM GetArrayElements(message.Body.NewRx.MedicationPrescribed)
) AS mp
-- 展开Observation数组，仅保留第一个元素
CROSS APPLY (
    SELECT TOP 1 * 
    FROM GetArrayElements(message.Body.NewRx.Observation)
) AS obs

关键修改点说明 #

1. CROSS APPLY GetArrayElements(...)展开数组：GetArrayElements会将数组的每个元素拆分为单独的行，CROSS APPLY则将这些元素与主记录关联起来，符合流式查询的编译规则。
2. SELECT TOP 1锁定第一个元素：确保我们只获取数组的第一个元素，和你原查询的需求一致。
3. 通过别名访问属性：展开后的数组元素通过mp、obs这类别名来访问内部属性，避免了原写法的嵌套问题。

处理数组为空的场景 #

如果你的数据中可能存在MedicationPrescribed或Observation数组为空的情况，建议把CROSS APPLY替换成OUTER APPLY——这样即使数组为空，主记录也不会被过滤掉，对应的属性值会显示为NULL。

为什么测试时能正常运行？ #

ASA的静态文件测试是在批处理模式下执行的，这种模式对函数的使用限制更宽松，允许直接嵌套GetArrayElement访问属性。但流式作业是实时处理，必须遵循更严格的流式查询语法规范，因此会触发编译错误。

内容的提问来源于stack exchange，提问作者Aditya Agarwal