使用 ADF 时在 cosmos DB 中序列化数组
Serializing Array inside cosmos DB when using ADF
我的 COSMOS DB 文档中有以下格式。
"Tag": "SPEEDSTER",
"data": [
{
"timestamp": "2018-09-05T13:55:09.297Z",
"jsonVersion": 1,
"speed": 404
}
]
在 ADF 复制管道中导入架构时,不支持数组。有什么办法可以实现吗?
您的接收器数据存储是什么?
如果您想按原样导出文档,例如,导出为 json 格式的文件,您可以使用按原样导出 json 功能。为此,您可以删除数据集中的结构和副本中的翻译器 activity。
https://docs.microsoft.com/en-us/azure/data-factory/connector-azure-cosmos-db#importexport-json-documents
如果您想从数组中提取数据,您可以编写自己的查询来进行一些转换。
您需要在副本 activity 中使用 sql 查询来设计您的 cosmos 数据库源数据的架构。
我上面sql根据你的示例数据测试,成功复制到blob存储中的txt文件。
select c.id,c.Tag,data.timestamp,data.jsonVersion,data.speed from c
输出:
希望对你有帮助。
我的 COSMOS DB 文档中有以下格式。
"Tag": "SPEEDSTER",
"data": [
{
"timestamp": "2018-09-05T13:55:09.297Z",
"jsonVersion": 1,
"speed": 404
}
]
在 ADF 复制管道中导入架构时,不支持数组。有什么办法可以实现吗?
您的接收器数据存储是什么?
如果您想按原样导出文档,例如,导出为 json 格式的文件,您可以使用按原样导出 json 功能。为此,您可以删除数据集中的结构和副本中的翻译器 activity。 https://docs.microsoft.com/en-us/azure/data-factory/connector-azure-cosmos-db#importexport-json-documents
如果您想从数组中提取数据,您可以编写自己的查询来进行一些转换。
您需要在副本 activity 中使用 sql 查询来设计您的 cosmos 数据库源数据的架构。
我上面sql根据你的示例数据测试,成功复制到blob存储中的txt文件。
select c.id,c.Tag,data.timestamp,data.jsonVersion,data.speed from c
输出:
希望对你有帮助。