Jay*_*279 7 arrays json jq jsonlines
首先,我刚接触jq
,就像1天新,我也是JSON的新手,我是一个SQL家伙,所以我学得很快,但无法理解这个...所以请耐心等待我.
我在PowerShell上使用jq v1.5运行Windows.
我下载了多个JSON文件,它们看起来像这样:
{"Header":{"AssetClass":"Commodities","InstrumentType":"Forward","UseCase":"Forward","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"EUR","ExpiryDate":"2018-01-01","ReturnorPayoutTrigger":"Contract for Difference (CFD)","DeliveryType":"CASH","BaseProduct":"AGRI","TransactionType":"FUTR","FinalPriceType":"ARGM","ReferenceRate":"10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN","SubProduct":"GROS","AdditionalSubProduct":"FWHT"},"ISIN":{"ISIN":"EZX27M86B860","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","UnderlyingAssetType":"Agriculture","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"FullName":"Commodities Forward AGRI GROS FWHT EUR 20180101","ShortName":"NA/Fwd AGRI FWHT EUR 20180101","ClassificationType":"JTAXCC"}}
{"Header":{"AssetClass":"Commodities","InstrumentType":"Swap","UseCase":"Basis_Swap","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"SOS","ExpiryDate":"2208-12-10","ReturnorPayoutTrigger":"Total Return","DeliveryType":"OPTL","TransactionType":"ORIT","FinalPriceType":"IHSM","ReferenceRate":"NATURAL GAS-MONTHLY INDEX S. TEXAS (TETCO)-GAS DAILY PRICE GUIDE","OtherReferenceRate":"NATURAL GAS-MONTHLY INDEX W. LOUISIANA (TETCO)-GAS DAILY PRICE GUIDE","BaseProduct":"OTHR","OtherBaseProduct":"OTHR","SubProduct":"","AdditionalSubProduct":"","OtherSubProduct":"","OtherAdditionalSubProduct":""},"ISIN":{"ISIN":"EZBBH1XR9GV6","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","UnderlyingAssetType":"Multi Commodity","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"FullName":"Commodities Swap Basis_Swap OTHR OTHR SOS 22081210","ShortName":"NA/Swap OTHR SOS 22081210","ClassificationType":"STQTXE"}}
{"Header":{"AssetClass":"Commodities","InstrumentType":"Swap","UseCase":"Multi_Exotic_Swap","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"LRD","ExpiryDate":"2200-01-31","ReturnorPayoutTrigger":"Contract for Difference (CFD)","DeliveryType":"CASH","TransactionType":"TAPO","FinalPriceType":"EXOF","UnderlyingInstrumentIndex":["BCOMF6","BCOMNG3"]},"ISIN":{"ISIN":"EZ286HJVY4Q2","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"UnderlyingAssetType":"Multi Commodity","BaseProduct":"MCEX","SubProduct":"","AdditionalSubProduct":"","FullName":"Commodities Multi_Exotic_Swap MCEX LRD 22000131","ShortName":"NA/Swap MCEX LRD 22000131","ClassificationType":"STQCXC"}}
{"Header":{"AssetClass":"Commodities","InstrumentType":"Option","UseCase":"Option","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"TND","ExpiryDate":"2209-10-18","OptionType":"OPTL","OptionExerciseStyle":"AMER","ValuationMethodorTrigger":"Asian","DeliveryType":"CASH","TransactionType":"OTHR","FinalPriceType":"IHSM","ReferenceRate":"NATURAL GAS-NGPL (NICOR, NIPSCO, PGLC CITYGATE), NBPL-NICOR-ICE/10X MONTHLY","BaseProduct":"OTHR","SubProduct":"","AdditionalSubProduct":""},"ISIN":{"ISIN":"EZ2TK5CWL9Y4","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","UnderlyingAssetType":"Other","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"FullName":"Commodities Option OTHR TND 22091018","ShortName":"NA/O OTHR OPTL TND 22091018","ClassificationType":"HTMHAC"}}
{"Header":{"AssetClass":"Commodities","InstrumentType":"Option","UseCase":"Multi_Exotic_Option","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"SOS","ExpiryDate":"2209-10-18","UnderlyingInstrumentIndex":["BCOMSI2","BCOMPR3T"],"OptionType":"CALL","OptionExerciseStyle":"AMER","ValuationMethodorTrigger":"Other Path Dependent","DeliveryType":"CASH","TransactionType":"ORIT","FinalPriceType":"BLTC"},"ISIN":{"ISIN":"EZ82L36B6225","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"UnderlyingAssetType":"Multi Commodity","BaseProduct":"MCEX","SubProduct":"","AdditionalSubProduct":"","FullName":"Commodities Multi_Exotic_Option MCEX SOS 22091018","ShortName":"NA/O MCEX Call SOS 22091018","ClassificationType":"HTQBPC"}}
Run Code Online (Sandbox Code Playgroud)
这些文件的大小可以超过1 GB.
为了让我有效地使用它们,我需要将JSON行转换为JSON数组,包装文件,前缀"["并附加"]",并为每行分隔逗号(,).
使文件看起来像这样(理论上):
[
{
"Header": {
"AssetClass": "Commodities",
"InstrumentType": "Swap",
"UseCase": "Basis_Swap",
"Level": "InstRefDataReporting"
},
"Attributes": {
"NotionalCurrency": "EUR",
"ExpiryDate": "2017-08-31",
"ReturnorPayoutTrigger": "Contract for Difference (CFD)",
"DeliveryType": "CASH",
"BaseProduct": "AGRI",
"OtherBaseProduct": "AGRI",
"TransactionType": "FUTR",
"FinalPriceType": "ARGM",
"ReferenceRate": "10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN",
"OtherReferenceRate": "10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN",
"SubProduct": "GROS",
"AdditionalSubProduct": "FWHT",
"OtherSubProduct": "GROS",
"OtherAdditionalSubProduct": "FWHT"
},
"ISIN": {
"ISIN": "EZ68CZDRFYY7",
"Status": "New"
},
"TemplateVersion": 1,
"Derived": {
"CommodityDerivativeIndicator": "TRUE",
"UnderlyingAssetType": "Multi Commodity",
"IssuerorOperatoroftheTradingVenueIdentifier": "NA",
"PriceMultiplier": 1,
"FullName": "Commodities Swap Basis_Swap AGRI GROS FWHT AGRI GROS FWHT EUR 20170831",
"ShortName": "NA/Swap AGRI FWHT FWHT EUR 20170831",
"ClassificationType": "STQCXC"
}
},
{
"Header": {
"AssetClass": "Commodities",
"InstrumentType": "Swap",
"UseCase": "Basis_Swap",
"Level": "InstRefDataReporting"
},
"Attributes": {
"NotionalCurrency": "EUR",
"ExpiryDate": "2017-08-31",
"ReturnorPayoutTrigger": "Contract for Difference (CFD)",
"DeliveryType": "CASH",
"BaseProduct": "AGRI",
"OtherBaseProduct": "AGRI",
"TransactionType": "FUTR",
"FinalPriceType": "ARGM",
"ReferenceRate": "10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN",
"OtherReferenceRate": "10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN",
"SubProduct": "GROS",
"AdditionalSubProduct": "FWHT",
"OtherSubProduct": "GROS",
"OtherAdditionalSubProduct": "FWHT"
},
"ISIN": {
"ISIN": "EZ68CZDRFYY7",
"Status": "New"
},
"TemplateVersion": 1,
"Derived": {
"CommodityDerivativeIndicator": "TRUE",
"UnderlyingAssetType": "Multi Commodity",
"IssuerorOperatoroftheTradingVenueIdentifier": "NA",
"PriceMultiplier": 1,
"FullName": "Commodities Swap Basis_Swap AGRI GROS FWHT AGRI GROS FWHT EUR 20170831",
"ShortName": "NA/Swap AGRI FWHT FWHT EUR 20170831",
"ClassificationType": "STQCXC"
}
}
]
Run Code Online (Sandbox Code Playgroud)
所以我找到了jq,根据我的理解,我可以运行它
jq --slurp 'map(select(. >= 2))' Inputfile.json > OutputFile.json
Run Code Online (Sandbox Code Playgroud)
这可以工作但是当运行大于200 MB的文件时,我得到"系统内存不足"错误(如果我使用ISE)并且如果我使用标准Powershell或CMD则需要很长时间.分钟(5+)
如果我取消--slurp
命令,它可以工作,它更快,但结果如下所示:
[
{
"Header": {
"AssetClass": "Commodities",
"InstrumentType": "Swap",
"UseCase": "Basis_Swap",
"Level": "InstRefDataReporting"
},
"Attributes": {
"NotionalCurrency": "EUR",
"ExpiryDate": "2017-08-31",
"ReturnorPayoutTrigger": "Contract for Difference (CFD)",
"DeliveryType": "CASH",
"BaseProduct": "AGRI",
"OtherBaseProduct": "AGRI",
"TransactionType": "FUTR",
"FinalPriceType": "ARGM",
"ReferenceRate": "10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN",
"OtherReferenceRate": "10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN",
"SubProduct": "GROS",
"AdditionalSubProduct": "FWHT",
"OtherSubProduct": "GROS",
"OtherAdditionalSubProduct": "FWHT"
},
"ISIN": {
"ISIN": "EZ68CZDRFYY7",
"Status": "New"
},
"TemplateVersion": 1,
"Derived": {
"CommodityDerivativeIndicator": "TRUE",
"UnderlyingAssetType": "Multi Commodity",
"IssuerorOperatoroftheTradingVenueIdentifier": "NA",
"PriceMultiplier": 1,
"FullName": "Commodities Swap Basis_Swap AGRI GROS FWHT AGRI GROS FWHT EUR 20170831",
"ShortName": "NA/Swap AGRI FWHT FWHT EUR 20170831",
"ClassificationType": "STQCXC"
}
}]
[{
"Header": {
"AssetClass": "Commodities",
"InstrumentType": "Swap",
"UseCase": "Basis_Swap",
"Level": "InstRefDataReporting"
},
"Attributes": {
"NotionalCurrency": "EUR",
"ExpiryDate": "2017-08-31",
"ReturnorPayoutTrigger": "Contract for Difference (CFD)",
"DeliveryType": "CASH",
"BaseProduct": "AGRI",
"OtherBaseProduct": "AGRI",
"TransactionType": "FUTR",
"FinalPriceType": "ARGM",
"ReferenceRate": "10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN",
"OtherReferenceRate": "10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN",
"SubProduct": "GROS",
"AdditionalSubProduct": "FWHT",
"OtherSubProduct": "GROS",
"OtherAdditionalSubProduct": "FWHT"
},
"ISIN": {
"ISIN": "EZ68CZDRFYY7",
"Status": "New"
},
"TemplateVersion": 1,
"Derived": {
"CommodityDerivativeIndicator": "TRUE",
"UnderlyingAssetType": "Multi Commodity",
"IssuerorOperatoroftheTradingVenueIdentifier": "NA",
"PriceMultiplier": 1,
"FullName": "Commodities Swap Basis_Swap AGRI GROS FWHT AGRI GROS FWHT EUR 20170831",
"ShortName": "NA/Swap AGRI FWHT FWHT EUR 20170831",
"ClassificationType": "STQCXC"
}
}
]
Run Code Online (Sandbox Code Playgroud)
它为每一行创建一个数组,但该数组不是逗号分隔的,这不是我想要的.
那么,我如何处理大型文件,多个JSON行,并为生成为单个数组的输入文件创建一个文件,逗号分隔,而不使用slurp?
我读过有关输入但不确定这是否与我需要做的有关?
Sha*_*Ali 24
也许,我迟到了,但这就是你要找的!
jq -s '.' in.json > out.json
Run Code Online (Sandbox Code Playgroud)
Tho*_*hor 11
它似乎与inputs
slurp 一样遭受同样的问题.我不知道如何jq
在巨大的文件上实现这一点,但sed
可以做到:
sed '1s/^/[/; $!s/$/,/; $s/$/]/' in.json > out.json
Run Code Online (Sandbox Code Playgroud)
输出:
[{"Header":{"AssetClass":"Commodities","InstrumentType":"Forward","UseCase":"Forward","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"EUR","ExpiryDate":"2018-01-01","ReturnorPayoutTrigger":"Contract for Difference (CFD)","DeliveryType":"CASH","BaseProduct":"AGRI","TransactionType":"FUTR","FinalPriceType":"ARGM","ReferenceRate":"10PPM ULTRA LOW SULPHUR DIESEL-CARGOES CIF NWE/BASIS ARA-PLATTS EUROPEAN","SubProduct":"GROS","AdditionalSubProduct":"FWHT"},"ISIN":{"ISIN":"EZX27M86B860","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","UnderlyingAssetType":"Agriculture","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"FullName":"Commodities Forward AGRI GROS FWHT EUR 20180101","ShortName":"NA/Fwd AGRI FWHT EUR 20180101","ClassificationType":"JTAXCC"}},
{"Header":{"AssetClass":"Commodities","InstrumentType":"Swap","UseCase":"Basis_Swap","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"SOS","ExpiryDate":"2208-12-10","ReturnorPayoutTrigger":"Total Return","DeliveryType":"OPTL","TransactionType":"ORIT","FinalPriceType":"IHSM","ReferenceRate":"NATURAL GAS-MONTHLY INDEX S. TEXAS (TETCO)-GAS DAILY PRICE GUIDE","OtherReferenceRate":"NATURAL GAS-MONTHLY INDEX W. LOUISIANA (TETCO)-GAS DAILY PRICE GUIDE","BaseProduct":"OTHR","OtherBaseProduct":"OTHR","SubProduct":"","AdditionalSubProduct":"","OtherSubProduct":"","OtherAdditionalSubProduct":""},"ISIN":{"ISIN":"EZBBH1XR9GV6","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","UnderlyingAssetType":"Multi Commodity","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"FullName":"Commodities Swap Basis_Swap OTHR OTHR SOS 22081210","ShortName":"NA/Swap OTHR SOS 22081210","ClassificationType":"STQTXE"}},
{"Header":{"AssetClass":"Commodities","InstrumentType":"Swap","UseCase":"Multi_Exotic_Swap","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"LRD","ExpiryDate":"2200-01-31","ReturnorPayoutTrigger":"Contract for Difference (CFD)","DeliveryType":"CASH","TransactionType":"TAPO","FinalPriceType":"EXOF","UnderlyingInstrumentIndex":["BCOMF6","BCOMNG3"]},"ISIN":{"ISIN":"EZ286HJVY4Q2","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"UnderlyingAssetType":"Multi Commodity","BaseProduct":"MCEX","SubProduct":"","AdditionalSubProduct":"","FullName":"Commodities Multi_Exotic_Swap MCEX LRD 22000131","ShortName":"NA/Swap MCEX LRD 22000131","ClassificationType":"STQCXC"}},
{"Header":{"AssetClass":"Commodities","InstrumentType":"Option","UseCase":"Option","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"TND","ExpiryDate":"2209-10-18","OptionType":"OPTL","OptionExerciseStyle":"AMER","ValuationMethodorTrigger":"Asian","DeliveryType":"CASH","TransactionType":"OTHR","FinalPriceType":"IHSM","ReferenceRate":"NATURAL GAS-NGPL (NICOR, NIPSCO, PGLC CITYGATE), NBPL-NICOR-ICE/10X MONTHLY","BaseProduct":"OTHR","SubProduct":"","AdditionalSubProduct":""},"ISIN":{"ISIN":"EZ2TK5CWL9Y4","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","UnderlyingAssetType":"Other","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"FullName":"Commodities Option OTHR TND 22091018","ShortName":"NA/O OTHR OPTL TND 22091018","ClassificationType":"HTMHAC"}},
{"Header":{"AssetClass":"Commodities","InstrumentType":"Option","UseCase":"Multi_Exotic_Option","Level":"InstRefDataReporting"},"Attributes":{"NotionalCurrency":"SOS","ExpiryDate":"2209-10-18","UnderlyingInstrumentIndex":["BCOMSI2","BCOMPR3T"],"OptionType":"CALL","OptionExerciseStyle":"AMER","ValuationMethodorTrigger":"Other Path Dependent","DeliveryType":"CASH","TransactionType":"ORIT","FinalPriceType":"BLTC"},"ISIN":{"ISIN":"EZ82L36B6225","Status":"New"},"TemplateVersion":1,"Derived":{"CommodityDerivativeIndicator":"TRUE","IssuerorOperatoroftheTradingVenueIdentifier":"NA","PriceMultiplier":1,"UnderlyingAssetType":"Multi Commodity","BaseProduct":"MCEX","SubProduct":"","AdditionalSubProduct":"","FullName":"Commodities Multi_Exotic_Option MCEX SOS 22091018","ShortName":"NA/O MCEX Call SOS 22091018","ClassificationType":"HTQBPC"}}]
Run Code Online (Sandbox Code Playgroud)
sed脚本由三个单独的替换组成.在这里它们分开:
1 s/^/[/ # Insert a left bracket at the beginning of the first line
$! s/$/,/ # On all but the last line append a comma
$ s/$/]/ # Append a right bracket to the last line
Run Code Online (Sandbox Code Playgroud)