I am having the data in Modbus TCP/IP. I have to read the available data with Apache NiFi. I don't know, which processor have to use exactly (Ex. GetTCP, ListenTCP, Plc4xSourceProcessor). Can you help me on this? Is there any feasibility with Apache NiFi?
How to read Modubus TCP/IP data with Apache NiFi?
1.8k Views Asked by Sathishkumar C At
2
There are 2 best solutions below
2
Bryan Bende
On
I don't really know what Modbus TCP/IP is, but it basically comes down to whether you want NiFi to be a client or a server.
ListenTCP creates a TCP server that is waiting for some client to make a connection and start sending data. The most common case would be a log forwarding system like syslog which can be configured to forward logs to a host/port over TCP.
GetTCP is a client that connects to some host/port which is the server, and starts reading data.
Plc4xSourceProcessor is not part of the official Apache NiFi code, but from quickly looking at it, it seems like more of a client processor similar to GetTCP since you give it a connection string telling it where to connect to.
Related Questions in TCP
- having spring integration tcpserver to manage clients and send them messages
- psuedo TCP multicast with os.dup2() in python?
- Retrieve Data From EOC(Eithernet Over coxial) device
- Connecting a web client to a c++ server with TCP
- ECONNRESET on node.js RabbitMQ consumer in Azure
- how to respond from plain tcp client to MessagingTemplate's sendAndReceive
- Java Socket - how does the read() method know if the end of stream has been reached?
- Scala - TCP Packet frame using Akka
- Re-transmission concept in TCP
- Issues regarding multiplayer networking: input
- Getting and Sending Data between a Server and Client
- Jamod Slave Example, can not connect to slave
- Android Phone not sending data over TCP/ip
- Lot of TIME_WAIT connections while using RestTemplate?
- How do I use the windows service and WCF to update some record in database?
Related Questions in APACHE-NIFI
- HTTP Error 404 when accessing nifi
- Only Sensitive values IN GetFile Processor?
- NiFi-1.0 - content_repo & flowfile_repo
- Best practices to handle errors in NIFI
- org.apache.nifi.bootstrap.Command Apache NiFi is not running
- ExecutionScript output two different flowfiles NIFI
- How to configure Apache NiFi for a Kerberized Hadoop Cluster
- Apache Nifi - get the file attributes and construct the json through custom processor
- How to save all entities in nifi ui into template using rest api?
- Remote NiFi input ports are not exposed
- Nifi executeprocess processor
- Access to queue attributes?
- NIFI JSON Jolt value mapping for keys
- How to create snippetID for all the processors,processgroups in the Entire UI using restapi in c#
- Migrate Dataflow NIFI
Related Questions in DATAFLOW
- failed to compile dataflow sample
- Run Magento 1.9.1.0 Dataflow Import Profile Programmatically
- TPL Dataflow block never completes on PropagateCompletion
- Error importing csv products in magento
- TPL Dataflow block consumes all available memory
- Remote NiFi input ports are not exposed
- Data transfer between components React-native
- Google Dataflow job failing continuously: "Pipe broken"
- Training and Prediction in Spark Streaming Machine Learning Model
- How can one create a data flow graph (DFG/SDFG) for any application from its source code
- The concept groupwin is like the unaligned windows?
- Data shows in BIDS preview but won't load when running
- How do I generate a data flow graph with clang or other tools?
- Dataflow from SPARQL to RDBMS in Virtuoso
- Troubleshooting apache beam pipeline import errors [BoundedSource objects is larger than the allowable limit]
Related Questions in MODBUS-TCP
- Socket get input stream reading wrong values few times
- Receive Heart, smiles from Modsim via TCP/IP
- Pymodbus/Twisted Asynchronous Client Reconnecting
- Modbus TCP/IP to BACnet
- pymodbus: request creation and response receiving
- Newbie in Python and pymodbusTCP
- Program a modbus touch panel to open a relay in a modbus relay board
- Modbus Protocol - MJK Device - Get Device ID ( Slave ID )
- pymodbus read_file_record operation does not seem to work
- How to tackle timeout error in Modbus TCP
- modbus tcp with king pigeon RTU5026
- modbus register conversion
- pymodbus : Modbus Error: [Input/Output] No Response received from the remote slave/Unable to decode response
- How to make Modbus TCP Server using Visual Studio 2022
- Modbus 485 Communication In Case of 2 or more Masters/Clients
Related Questions in PLC4X
- How to read Modubus TCP/IP data with Apache NiFi?
- Plc4x library Modbus serial (RTU) get is not retrieving data
- Can not write string into S7-1500 with Java
- How to solve this error when building PLC4X with Docker
- PLC4X:Exception during scraping of Job
- How to read the bit of switch of PLC in C# application
- "Unsupported case for discriminated type" when reading tag from Allen Bradley's Micro820 PLC, using Apache's PLC4X
- Kafka - PLC4X - Modbus/TCP - Exception during scraping of Job
- When collecting data with Modbus protocol through kafka Producer, collection stops after a certain period of time
- PLC4X OPCUA -Kafka Connnector
- PLC4x docker container connection timeout to PLC
- I am looking for and example of how to use Plc4xSinkProcessor in NiFi
- Unsolvable error with multiple requested values send to the plc (apache.plc4x)
- Modbus RTU over TCP
- Apache PLC4x connecting with Apache kafka , trying connect with Pro sys OPC simulator
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
the Plc4xSourceProcessor is what you are looking for. The Apache PLC4X project provides drivers for accessling PLCs using various protocols. One of the is the Modbus protocol. So if you use the Plc4xSourceProcessor and configure a modbus connection string and list the addresses you want to collect, then you will be able to do so.
I happen to have written the PLC4X-NiFi Integration documentation on our website just a couple of days ago: https://plc4x.apache.org/users/integrations/apache-nifi.html
I think this will be helpful.
Chris