pyRT.apps.feeds.Drop2sql Namespace Reference

Functions
def	DateTimeMs
	Return string-ified time as YYYY-MM-DD HH:MM:SS.mmm. More...
def	DumpOutfile
	Dump outfile. More...
def	FIX2odbc
	Convert FIX to ODBC. More...
def	LOG
	Log msg to stdout w/ timestamp. More...
def	MapFile
	Open / Map in file. More...
def	TimeMs
	Return string-ified time as HH:MM:SS.mmm. More...

Variables
tuple	argc = len( sys.argv )
	# main() # # More...
tuple	dst = ph.Dst()
tuple	fh = pcap.FileHdr( map[:32] )
tuple	fix = FIXMsg.FIXMsg( 'Drop', raw )
list	flds = [ sess, 'RX' ]
list	fp = kv[0]
tuple	iMB = sz/( 1024 * 1024 )
tuple	kv = MapFile( pf )
string	line = '\t'
list	map = kv[1]
tuple	mLen = rh._oLen-ph.Size()
tuple	mt = fix.GetField( FIXDict._fid_MsgType )
int	nf = 1
	LOAD DATA INFILE payload. More...
int	nPkt = 0
tuple	nr = len( rows )
tuple	off = fh.Size()
tuple	oMB = sz/( 1024 * 1024 )
list	pf = sys.argv[1]
tuple	ph = pcap.PktHdr( map[off:off+42] )
list	raw = map[off:off+mLen]
tuple	rh = pcap.RecHdr( map[off:off+20] )
	rOff = off
list	rows = []
	Number of Packets Processed. More...
string	s = '%dMb mapped in; '
tuple	sess = DateTimeMs()
tuple	src = ph.Src()
tuple	sz = len( map )
tuple	zap = gzip.decompress( map )

Function Documentation

def pyRT.apps.feeds.Drop2sql.DateTimeMs

(

)

Return string-ified time as YYYY-MM-DD HH:MM:SS.mmm.

Returns

string-ified time as YYYY-MM-DD HH:MM:SS.mmm

def pyRT.apps.feeds.Drop2sql.DumpOutfile	(		pFile,
			rows
	)

Dump outfile.

Parameters

pFile	- Output filename
rows	- Rows to dump

Returns

Empty list for next rows

def pyRT.apps.feeds.Drop2sql.FIX2odbc	(		fid,
			val
	)

Convert FIX to ODBC.

Parameters

fid	- FIX Field ID
val	- FIX Field Value

Returns

Converted Field Value

def pyRT.apps.feeds.Drop2sql.LOG	(		msg,
			bTs = True
	)

Log msg to stdout w/ timestamp.

Parameters

msg	- Message to log
bTs	- True to prepend timestamp

def pyRT.apps.feeds.Drop2sql.MapFile

(

filename

)

Open / Map in file.

Parameters

filename

- File to mmap()

Returns

[ fp, map, fSz ] on success; None on error

def pyRT.apps.feeds.Drop2sql.TimeMs

(

)

Return string-ified time as HH:MM:SS.mmm.

Returns

string-ified time as HH:MM:SS.mmm

Variable Documentation

tuple pyRT.apps.feeds.Drop2sql.argc = len( sys.argv )

               #

main() # #

tuple pyRT.apps.feeds.Drop2sql.dst = ph.Dst()

tuple pyRT.apps.feeds.Drop2sql.fh = pcap.FileHdr( map[:32] )

tuple pyRT.apps.feeds.Drop2sql.fix = FIXMsg.FIXMsg( 'Drop', raw )

list pyRT.apps.feeds.Drop2sql.flds = [ sess, 'RX' ]

list pyRT.apps.feeds.Drop2sql.fp = kv[0]

pyRT.apps.feeds.Drop2sql.iMB = sz/( 1024 * 1024 )

tuple pyRT.apps.feeds.Drop2sql.kv = MapFile( pf )

string pyRT.apps.feeds.Drop2sql.line = '\t'

pyRT.apps.feeds.Drop2sql.map = kv[1]

tuple pyRT.apps.feeds.Drop2sql.mLen = rh._oLen-ph.Size()

tuple pyRT.apps.feeds.Drop2sql.mt = fix.GetField( FIXDict._fid_MsgType )

int pyRT.apps.feeds.Drop2sql.nf = 1

LOAD DATA INFILE payload.

int pyRT.apps.feeds.Drop2sql.nPkt = 0

tuple pyRT.apps.feeds.Drop2sql.nr = len( rows )

tuple pyRT.apps.feeds.Drop2sql.off = fh.Size()

tuple pyRT.apps.feeds.Drop2sql.oMB = sz/( 1024 * 1024 )

list pyRT.apps.feeds.Drop2sql.pf = sys.argv[1]

tuple pyRT.apps.feeds.Drop2sql.ph = pcap.PktHdr( map[off:off+42] )

list pyRT.apps.feeds.Drop2sql.raw = map[off:off+mLen]

tuple pyRT.apps.feeds.Drop2sql.rh = pcap.RecHdr( map[off:off+20] )

pyRT.apps.feeds.Drop2sql.rOff = off

tuple pyRT.apps.feeds.Drop2sql.rows = []

Number of Packets Processed.

string pyRT.apps.feeds.Drop2sql.s = '%dMb mapped in; '

tuple pyRT.apps.feeds.Drop2sql.sess = DateTimeMs()

tuple pyRT.apps.feeds.Drop2sql.src = ph.Src()

tuple pyRT.apps.feeds.Drop2sql.sz = len( map )

tuple pyRT.apps.feeds.Drop2sql.zap = gzip.decompress( map )