Is there any help ?
On Saturday, January 21, 2017, sam mohel <[email protected]> wrote:
> I'm new to python , i'm trying to make spout read from file line by line .
> i tried to write this statments but didn't work
>
>
> import storm
> import random
> # Define some sentences
>
> class SimSpout(storm.Spout):
> # Not much to do here for such a basic spout
> def initialize(self, conf, context):
> ## Open the file with read only permit
> f = open('mydata.txt', 'r')
> self._conf = conf
> self._context = context
>
> storm.logInfo("Spout instance starting...")
>
> # Process the next tuple
> def nextTuple(self):
> # check if it reach at the EOF to close it
> line = f.readline()
> while line != "":
> # Emit a random sentence
> storm.logInfo("Emiting %s" % line)
> storm.emit([line])
>
> # Start the spout when it's invoked
> SimSpout().run()
>
> Another thing i want to ask about , i have shell script that take my data
> text file to make process on it to get the result , now if i want to make
> it in storm i should make spout open my data text file as its my data
> source and read line by line to take every line it got it to bolt that make
> a process on it which will contain the code in shell written in python ,
> Right ?
>
