FilesExpand file tree

 main

/

coticker.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

66 lines (51 loc) · 1.4 KB

 main

/

coticker.py

Copy path

Top

File metadata and controls

• Code
• Blame

66 lines (51 loc) · 1.4 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

from structure import Structure

from cofollow import consumer, follow

from tableformat import create_formatter

import csv

class Ticker(Structure):

name = String()

price = Float()

date = String()

time = String()

change = Float()

open = Float()

high = Float()

low = Float()

volume = Integer()

# Coroutine that splits rows using the CSV module. This is rather

# mind-bending due to the fact that the csv module only understands

# iteration with the for-loop. To make it work, we wrap it around

# a generator that simply produces the last item received.

@consumer

def to_csv(target):

def producer():

while True:

yield line

reader = csv.reader(producer())

while True:

line = yield

target.send(next(reader))

@consumer

def create_ticker(target):

while True:

row = yield

target.send(Ticker.from_row(row))

@consumer

def negchange(target):

while True:

record = yield

if record.change < 0:

target.send(record)

@consumer

def ticker(fmt, fields):

formatter = create_formatter(fmt)

formatter.headings(fields)

while True:

rec = yield

row = [getattr(rec, name) for name in fields]

formatter.row(row)

if __name__ == "__main__":

follow(

"Data/stocklog.csv",

to_csv(create_ticker(negchange(ticker("text", ["name", "price", "change"])))),

)