hl7消息編碼錯誤，同時解析map-reduce中的消息

我試圖通過Hapi解析HL7消息在map-reduce函數中我得到了EncodingNotSupportedException當我運行地圖任務時。我試圖添加\ n或\ r到每個段的結尾，但我面臨着同樣的錯誤。消息保存在文本文件中並上傳到HDFS。我應該需要補充的東西，這是我的代碼hl7消息編碼錯誤，同時解析map-reduce中的消息

String v = value.toString(); 

InputStream is = new StringBufferInputStream(v);   
is = new BufferedInputStream(is);  
Hl7InputStreamMessageStringIterator iter = new Hl7InputStreamMessageStringIterator(
        is); 

    HapiContext hcontext = new DefaultHapiContext(); 
    Message hapiMsg; 
    Parser p = hcontext.getGenericParser(); 

    while (iter.hasNext()) { 

     String msg = iter.next(); 

     try { 
      hapiMsg = p.parse(msg); 
     } catch (EncodingNotSupportedException e) { 
      e.printStackTrace(); 
      return; 
     } catch (HL7Exception e) { 
      e.printStackTrace(); 
      return; 
     } 
    }

樣本消息

MSH|^~\&|HIS|RIH|EKG|EKG|20150121002000||ADT^A01||P|2.5.1 
EVN||20150121002000|||||CITY GENL HOSP^0133195934^NPI 
PID|1||95101100001^^^^PI^CITY GENL HOSP&0133195934&NPI||SNOW^JOHN^^^MR^^L||19560121002000|M||2054-5^White^CDCREC|470 Ocean Ave^^NEW YORK^^11226^USA^C^^29051||^^^^^513^5551212|||||95101100001||||2186-5^White American^CDCREC|||1 
PV1||E||E||||||||||1|||||||||||||||||||||||||||||| 
OBX|1|NM|21612-7^PATIENT AGE REPORTED^LN||60|a^YEAR^UCUM|||||F|||201601131443 
OBX|2|NM|21613-7^Urination^LN||2|a^DAY^UCUM|||||F|||19740514201500 
DG1|001||4158^Diabetes^I9CDX||19740514201500|A|5478^Non-infectious 
DG1|002||2222^Huntington^I9CDX||19610718121500|A|6958^Genetic

來源

2016-04-26 Zaman

可能是PipeParser會幫你處理編碼。 –

我也使用它，我也有同樣的錯誤 – Zaman

告訴我們，消息是怎樣的！切勿將HL7消息存儲爲文本文件，而是以二進制形式存儲。你確定，分段分隔符好嗎？ – sqlab

決不店HL7的消息爲文本文件，但作爲二進制文件。你確定，分段分隔符好嗎？

從HDFS讀取HDFS消息後，只需通過打印到控制檯或通過使用調試器，如果消息在分析前僅包含\r作爲段分隔符，那麼只需檢查您的HL7消息。

段定界符必須是\r，即x0d，「回車」而不是\n，即x0a「換行符」。有可能有一些工具，可能是HL7編輯器，接受可選的分隔符或編寫錯誤的分隔符，但這不是標準。

來源

2016-04-29 09:59:56 sqlab

hl7消息編碼錯誤，同時解析map-reduce中的消息

回答

相關問題