如何在Azure Stream Analytics中按逗号分割CSV字符串映射到SQL列

核心方法 #

直接使用Azure Stream Analytics查询语法内置的原生函数即可完成拆分，无需适配普通SQL的自定义分割函数：

• STRING_SPLIT(待拆分字符串, 分隔符)：将字符串按指定分隔符拆分，返回索引从0开始的数组
• GetArrayElement(数组, 索引值)：提取数组对应索引位置的元素值

示例查询代码 #

假设你的输入流别名是InputStream，CSV整行内容存储在输入流的rawContent字段中，SQL输出别名是SQLOutput，查询写法如下：

SELECT
  -- 按字段顺序对应索引从0开始取值
  GetArrayElement(STRING_SPLIT(rawContent, ','), 0) AS name,
  CAST(GetArrayElement(STRING_SPLIT(rawContent, ','), 1) AS INT) AS age,
  GetArrayElement(STRING_SPLIT(rawContent, ','), 2) AS address,
  GetArrayElement(STRING_SPLIT(rawContent, ','), 3) AS phone,
  GetArrayElement(STRING_SPLIT(rawContent, ','), 4) AS result1,
  GetArrayElement(STRING_SPLIT(rawContent, ','), 5) AS result2,
  GetArrayElement(STRING_SPLIT(rawContent, ','), 6) AS result3
  -- 后续resultN字段按索引顺序依次添加即可
INTO
  SQLOutput
FROM
  InputStream

注意事项 #

• 如果你的CSV字段本身包含逗号（例如地址字段内容带逗号），不建议使用手动拆分的方式。可以直接在ASA的输入配置中将序列化格式设置为CSV，ASA会自动识别标准带引号的CSV格式完成字段解析，无需编写额外拆分逻辑。
• 非字符串类型的字段（例如年龄、数值类结果）需要使用CAST函数转换为和目标SQL表匹配的类型，避免写入报错。

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