Member since
10-12-2017
17
Posts
1
Kudos Received
0
Solutions
11-21-2018
07:17 AM
I have removed the special characters from the starting of the message and end of the messages. But at the end of message I am getting one extra space/line. Will that cause the issue when the ExtractHL7 attribute processor process HL7?
... View more
11-15-2018
10:53 AM
As the existing GETTCP/ListenTCP NiFi processors are not supporting of Receiving and acknowlidging HL7 messages, I have created NiFi custom processor for receiving MLLP based HL7 message and sending acknowledgement. The custom processor works fine(output flow file has the same HL7 message which I sent from simulator) but when I send the received HL7 message to ExtractHL7Attributes processor I am getting error "ca.uhn.hl7v2.parser.EncodingNotSupportedException: Determine encoding for message." From the detailed error message below I thought that the MLLP Protocol's special characters (VT and FS) wrapping the HL7 message are causing the error So I replaced those from the code with the empty value. Then sent the flow through replace text for replacing the CR carriage return with \r\n and then the flow was sent to ExtractHL7Attributes processor. Here I am getting the same error which I mentioned below, except those special characters.
More details:
I am using the Sample HL7 message for testing my custom processor I am using iNTERFACEHL7 simulator (also tried with 7Edit trial version).
But the same HL7, which I sent through generate flow file is always working fine. Its extract the HL7 attributes and values. Even after removing the special characters and set the encoding character set to UTF-8 I am getting the below error. Can someone help me on what could be the issue? Uploaded my custom processor code and Flow:
ERROR [Timer-Driven Process Thread-4] o.a.n.p.hl7.ExtractHL7Attributes ExtractHL7Attributes[id=cd04bcf2-0166-1000-bdf4-f8edf35f2ee0] Failed to extract attributes from StandardFlowFileRecord[uuid=20c6a503-b2f8-4fe0-944c-aea8cf5be0ac,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1541774898083-1, container=default, section=1], offset=10240, length=10456],offset=0,name=45793985248400,size=10456] due to ca.uhn.hl7v2.parser.EncodingNotSupportedException: Determine encoding for message. The following is the first 50 chars of the message for reference, although this may not be where the issue is:
MSH|^~\&|XXXX^XXXX^EUI-: ca.uhn.hl7v2.parser.EncodingNotSupportedException: Determine encoding for message. The following is the first 50 chars of the message for reference, although this may not be where the issue is:
MSH|^~\&XXXX^XXXXEUI- ca.uhn.hl7v2.parser.EncodingNotSupportedException: Determine encoding for message. The following is the first 50 chars of the message for reference, although this may not be where the issue is:
MSH|^~\&|XXXX^XXXX^EUI- at ca.uhn.hl7v2.parser.Parser.parse(Parser.java:201) at ca.uhn.hl7v2.parser.PipeParser.parse(PipeParser.java:1018) at org.apache.nifi.processors.hl7.ExtractHL7Attributes.onTrigger(ExtractHL7Attributes.java:199) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1165) at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:203) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117) at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) at java.util.concurrent.FutureTask.runAndReset(Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source) at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.lang.Thread.run(Unknown Source) Tried the below links. But no luck. http://apache-nifi-users-list.2361937.n4.nabble.com/Extract-HL7-Attributes-td3760.html https://community.hortonworks.com/articles/138249/nifi-in-healthcare-ingesting-hl7-data-in-nifi.html
... View more
Labels:
- Labels:
-
Apache Hive
11-15-2018
07:58 AM
@Michael Young I have created the custom processor to solve the issue. But currently I am stuck with HL7 message processing and I have created a new question on that here https://community.hortonworks.com/questions/226511/extracthl7attribute-processor-throws-error-cauhnhl.html. Can you please let me know your suggestion on that? Thank you
... View more
11-15-2018
07:54 AM
Hi @Muki Soomar Thanks for extending your help on this. I have created the custom processor to solve the above issue. But the answer for your question and the issue which I currently stuck with during HL7 message processing are posted in the link https://community.hortonworks.com/questions/226511/extracthl7attribute-processor-throws-error-cauhnhl.html. Please have a look on that and let me know your inputs on that. Thanks again..
... View more
10-03-2018
02:07 PM
@Muki Soomar Thanks for the template it will help me during my implementation. But I am stuck with the first step that is listening for the message over ListenTCP Processor. In the template which you shared It has generate flow file which send HL7 message and it flow through PutTCP. This work for me. But instead of generate flow file I tried using different HL7 simulators. But I am not able to receive in ListenTCP Processor. Now I am in the process of creating a custom processor on top of ListenTCP which will receive the HL7 message and also send back the acknowledgement.
... View more
10-03-2018
01:29 PM
I am unable to receive even after adjusting the buffer size. Now I am in the process of creating a custom processor on top of ListenTCP which will receive the HL7 message and also send back the acknowledgement. If anyone have an idea or implemented the same please share me the steps which will reduce my development time in creating the custom processor. Thanks
... View more
09-25-2018
09:30 AM
Hi @Michael Young @Timothy Spann @Matt Clarke @Matt Burgess@anarasimham I am trying to receive the Hl7 message from Simulator to Listen TCP but I am not able to receive it. Any directions from here will be helpful. So far what I have tried are 1. Sent the same message HL7 from console application to ListenTCP Processor I am able to receive message in Processor 2. Also from the simulator to Console application I am able to pass the HL7 message through the port configured. Attached the screenshot.
... View more
09-24-2018
12:21 PM
Hi @Timothy Spann Thanks for the Links. I followed the links mentioned. But I want the HL7 message directly to NiFi so that I can do further processing on NiFi Processors and send to my back end. I don't want the HL7 message to write into some file and send to NiFi. Because I want to avoid the time it takes to write into file and send to NiFi. Is it possible? Or any other alternative ? And I am using iNTERFACEHL7 Simulator. I tested the Simulator. I am able to receive the HL7 message in my console which I send through Simulator. Problem is, NiFi Processor are unable to receive HL7 messages.
... View more
09-24-2018
10:39 AM
I didn't get any errors rather didn't receive the data packet.
... View more
09-21-2018
02:55 PM
1 Kudo
In my scenario I want to receive the HL7 message from a HL7 simulator or through some asset which send the HL7 message to the configured IP:Port. I tried two ways for receiving HL7 message 1. Through ListenTCP and GetTCP processors. But with these Processor I am unable to receive the HL7 message in NiFi. 2. Tried the steps mentioned in Ingesting HL7 Data in NiFi. To follow this I need the Kafka Set up. For that I followed the steps mentioned on the kafka site for installing Kafka. Also verified the installation by running the Kafka Producer and Consumer bat file. As a next step instead of Kafka Consumer console, I used NiFi ConsumeKafka Processor as a Consumer. The data I sent from Kafka Producer console was received in ConsumeKafka Processor which I tested by sending the data through PutFile Processor. But here the problem is I don't have a configuration section where I can mention topic. I can only set the IP, Port and Message in the HL7 simulator app. Is there any Processor which can receive the HL7 data by configuring Ip and Port. Or any suggestions/help on receiving HL7 message into NiFi will be really helpful. Thanks.
... View more
Labels:
- Labels:
-
Apache Hive
-
Apache Kafka
-
Apache NiFi