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 answers
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
- Java SocketException: Connection reset,. What is the cause?
- How does a server handle multiple requests, and how does is know where to send which response?
- How does pre-allocating a pool of SocketAsyncEventArgs objects upfront improve the performance of a server application in c#
- How to peek or ready to check whether HTTP request or not in TCP proxy?
- How does bash > /dev/tcp/"ip"/"port 0<&1 keep its connection alive?
- Python TCP Server that both sends and or receives data (independently) using asyncio streams?
- Can't remotely connect to my postgresql database on digitalocean
- Why my message doesn't write into the socket when I try to read the response after sending it?
- What makes MQTT a raw tcp connection that we can't run it in the browser?
- ImGui rendering wrong characters (characters received from tcp sockets)
- TCP/IP Server Using sockets Java
- C# tcp socket keepalive I want to visit a website, but the specified time is very slow and I cannot access it
- Java TCP socket want to multiple times input with one connection
- How do I receive TCP messages on an android Emulator from a physcal device
- Getting error while using the MessagePattern to communicate between microservices
Related Questions in APACHE-NIFI
- How to split a flow file json in nifi
- Nifi queryrecord compare regex using rpath on first level of record
- How to compare two csv files line by line in apachi nifi flow file using groovy script
- Apache nifi Invoke Http with url containing %2F
- localhost 8443 refused to connect
- Apache NIFI: Unable to write flow content
- Copy/Merge multiple HDFS files using Nifi Processor
- How to count the number of records of a JSON object using JOLT
- Jolt to remove the slashes and extract the nested json
- Customize Apache Nifi Frontend
- Apache NIFI getMongo An unexpected error has occurred: The specified data reference URI is not valid
- Filter JSON Array to Keep Only the Entry with the Latest Date/Time Using Jolt
- How to get hold of input file from a flowfile?
- How to let Airflow know that a Ni-Fi pipeline involving multiple flows is complete
- Creating connection from RouteOnAttribute to GetFile
Related Questions in DATAFLOW
- Issue Pickling Dataflow Pipeline on Airflow
- How to convert SQL rows to an array of json objects in Azure Data Factory?
- Dataflow doesn’t create an empty partition when writing to a Bigquery time-unit column partition
- how to save logs from c++ binary in beam python?
- Google cloud data flow exmaple
- Apache Beam: WriteToFiles Based on Filename
- DataflowRunner "Cannot convert GlobalWindow to apache_beam.utils.windowed_value._IntervalWindowBase" using SlidingWindows yet DirectRunner works?
- Use apache beam arguments within the pipeline
- Pass/Refer a SQL file in Apache Beam instead of string
- Can not pass varible to region in MKCoordinateRegion in swift
- Dataflow- dynamic create disposition Apache Beam
- Read CSV to a class Dataflow Java from GCS
- Dataflow Job extracting meta information
- Output multiple tuples at same time in apache beam pipeline
- Dataflow WindowIntoBatches WithShardedKey error (Python)
Related Questions in MODBUS-TCP
- PortNotOpenError while connecting to Modbus
- How to use WiFi and Ethernet at same time?
- Telegraf interval varies too much with modbus inputs to influxdb
- PyModbusTCP reading different values than actual ModBus values?
- Python OPCUA, modbus communication code gets a RuntimeError after 3 hours of running
- Why can't read the correct data in python with modbus?
- starting address of the delta plc AS228p-A in Modbus TCP/Ip connection
- NModBus WriteMuitipleRegister Exception
- modbus c++ library modbuspp with X20PS9400a B&R
- Having difficultty communicating with Keyence NC32T PLC via ethernet using pymodbus
- Using PLC with Modbus/TCP to read external Schneider PM5320 register
- PHPModbus Fails to Connect
- insconsistent modbus server client relation
- EasyModbus Framework Read Bit from device
- Modbus 485 Communication In Case of 2 or more Masters/Clients
Related Questions in PLC4X
- Connection parameters for OPCUA with Basic256Sha256
- What is the best way to connect physical IOs (from sensors or whatever), to a twincat 3 program that uses OOP?
- How can I access S7-200 SMART using PLC4x in Java?
- How does plc4j Modbus switch to big endian
- Local Docker Image Status UP (unhealthy) does not get displayed in the control center
- Apache PLC4x connecting with Apache kafka , trying connect with Pro sys OPC simulator
- how to read field with Chinese
- memory leakage ,when write point to influxdb 2.2 invoked in a CompletionStage<PlcReadResponse>
- PLC4x docker container connection timeout to PLC
- When collecting data with Modbus protocol through kafka Producer, collection stops after a certain period of time
- PLC4X OPCUA -Kafka Connnector
- Kafka - PLC4X - Modbus/TCP - Exception during scraping of Job
- "Unsupported case for discriminated type" when reading tag from Allen Bradley's Micro820 PLC, using Apache's PLC4X
- How to read the bit of switch of PLC in C# application
- PLC4X: S7 Connection NullPointerException
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?
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)
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