Styjun

Multi tool use

"Estrontium" on poster

Double underlining a result in a system of equations with calculation steps on the right side

Is there a need for better software for writers?

What's the difference between "ricochet" and "bounce"?

How to get MAX value using SOQL when there are more than 50,000 rows

When do you stop "pushing" a book?

How to efficiently lower your karma in fallout 3

Why was Sam Wilson chosen for this, but not Bucky?

Lorentz invariance of Maxwell's equations in matter

How come mathematicians published in Annals of Eugenics?

How do I minimise waste on a flight?

Locked my sa user out

Are there vaccine ingredients which may not be disclosed ("hidden", "trade secret", or similar)?

How can I test a shell script in a "safe environment" to avoid harm to my computer?

How likely are Coriolis-effect-based quirks to develop in starship crew members?

Names of the Six Tastes

Is there an application which does HTTP PUT?

Was Mohammed the most popular first name for boys born in Berlin in 2018?

Identity of a supposed anonymous referee revealed through "Description" of the report

Using wilcox.test() and t.test() in R yielding different p-values

What are these round pads on the bottom of a PCB?

How is Arya still alive?

What is the radius of the circle in this problem?

Two (probably) equal real numbers which are not proved to be equal?

In the nifi flow, is there a way to append filename as part of each file sent to putKinesisStream processor

Apache Nifi - get the file attributes and construct the json through custom processorwhere to convert .xls file to json file inside Nifi data flow?custom nifi processor - writing of flow fileSpark Streaming with NifiNiFi Flowfile Attributes from KafkaConsumerCreating larger NiFi flow files when using the ConsumeKafka processorHow to assign a name to image which is getting stored from Nifi's PutFile Processor ? Name to be assigned and image appear in different flow fileAccessing lineage of a NiFi flow fileNifi Processor gets triggered twice for single Input flow fileApache NiFi GetMongoProcessor - not continuously producing flow files

.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty height:90px;width:728px;box-sizing:border-box;

0

I have a NIFI flow to read files from server and put to Kinesis Stream. I want to read the filename and append it as part of the files/records being sent to putKinesis processor.

NIFI Flow: ListSFTP -- FetchSFTP-- UpdateAttribute -- PutKineses Expected: Fetch filenames read from sftp server and append it to the records that are sent to PutKinesis so that while retrieving the messages user has an idea of tracking the message to which file it belongs to.

I'd like to append the filename to the data (body) which is being sent to Kinesis stream. How to achieve it?

apache-spark spark-streaming apache-nifi amazon-kinesis

share|improve this question

edited Mar 24 at 19:58

Jacek Laskowski

47.1k18141280

asked Mar 23 at 8:48

NikhilNikhil

1

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  You could do it with script, but better to provide example of your file content and expected result
  
  – daggett
  Mar 23 at 9:41
  

  
  
  
  

add a comment | 

0

I have a NIFI flow to read files from server and put to Kinesis Stream. I want to read the filename and append it as part of the files/records being sent to putKinesis processor.

NIFI Flow: ListSFTP -- FetchSFTP-- UpdateAttribute -- PutKineses Expected: Fetch filenames read from sftp server and append it to the records that are sent to PutKinesis so that while retrieving the messages user has an idea of tracking the message to which file it belongs to.

I'd like to append the filename to the data (body) which is being sent to Kinesis stream. How to achieve it?

apache-spark spark-streaming apache-nifi amazon-kinesis

share|improve this question

edited Mar 24 at 19:58

Jacek Laskowski

47.1k18141280

asked Mar 23 at 8:48

NikhilNikhil

1

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  You could do it with script, but better to provide example of your file content and expected result
  
  – daggett
  Mar 23 at 9:41
  

  
  
  
  

add a comment | 

I have a NIFI flow to read files from server and put to Kinesis Stream. I want to read the filename and append it as part of the files/records being sent to putKinesis processor.

NIFI Flow: ListSFTP -- FetchSFTP-- UpdateAttribute -- PutKineses Expected: Fetch filenames read from sftp server and append it to the records that are sent to PutKinesis so that while retrieving the messages user has an idea of tracking the message to which file it belongs to.

I'd like to append the filename to the data (body) which is being sent to Kinesis stream. How to achieve it?

apache-spark spark-streaming apache-nifi amazon-kinesis

share|improve this question

edited Mar 24 at 19:58

Jacek Laskowski

47.1k18141280

asked Mar 23 at 8:48

NikhilNikhil

1

share|improve this question

edited Mar 24 at 19:58

Jacek Laskowski

47.1k18141280

asked Mar 23 at 8:48

NikhilNikhil

1

share|improve this question

edited Mar 24 at 19:58

Jacek Laskowski

47.1k18141280

asked Mar 23 at 8:48

NikhilNikhil

1

edited Mar 24 at 19:58

Jacek Laskowski

47.1k18141280

edited Mar 24 at 19:58

Jacek Laskowski

47.1k18141280

asked Mar 23 at 8:48

NikhilNikhil

1

asked Mar 23 at 8:48

NikhilNikhil

1