commit
a479f1c26c
@ -0,0 +1,122 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: HFDataTableMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='HFDataTableMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x18HFDataTableMessage.proto\"\x86\x01\n\x10HFDataTableArray\x12\x34\n\tdataArray\x18\x01 \x03(\x0b\x32!.HFDataTableArray.HFDataTableData\x1a<\n\x0fHFDataTableData\x12\x0c\n\x04\x63ode\x18\x01 \x02(\t\x12\x0c\n\x04\x64\x61te\x18\x02 \x02(\x05\x12\r\n\x05\x42ytes\x18\x03 \x02(\x0c'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_HFDATATABLEARRAY_HFDATATABLEDATA = _descriptor.Descriptor(
|
||||||
|
name='HFDataTableData',
|
||||||
|
full_name='HFDataTableArray.HFDataTableData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='code', full_name='HFDataTableArray.HFDataTableData.code', index=0,
|
||||||
|
number=1, type=9, cpp_type=9, label=2,
|
||||||
|
has_default_value=False, default_value=b"".decode('utf-8'),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='date', full_name='HFDataTableArray.HFDataTableData.date', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='Bytes', full_name='HFDataTableArray.HFDataTableData.Bytes', index=2,
|
||||||
|
number=3, type=12, cpp_type=9, label=2,
|
||||||
|
has_default_value=False, default_value=b"",
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=103,
|
||||||
|
serialized_end=163,
|
||||||
|
)
|
||||||
|
|
||||||
|
_HFDATATABLEARRAY = _descriptor.Descriptor(
|
||||||
|
name='HFDataTableArray',
|
||||||
|
full_name='HFDataTableArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='HFDataTableArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_HFDATATABLEARRAY_HFDATATABLEDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=29,
|
||||||
|
serialized_end=163,
|
||||||
|
)
|
||||||
|
|
||||||
|
_HFDATATABLEARRAY_HFDATATABLEDATA.containing_type = _HFDATATABLEARRAY
|
||||||
|
_HFDATATABLEARRAY.fields_by_name['dataArray'].message_type = _HFDATATABLEARRAY_HFDATATABLEDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['HFDataTableArray'] = _HFDATATABLEARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
HFDataTableArray = _reflection.GeneratedProtocolMessageType('HFDataTableArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'HFDataTableData' : _reflection.GeneratedProtocolMessageType('HFDataTableData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _HFDATATABLEARRAY_HFDATATABLEDATA,
|
||||||
|
'__module__' : 'HFDataTableMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:HFDataTableArray.HFDataTableData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _HFDATATABLEARRAY,
|
||||||
|
'__module__' : 'HFDataTableMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:HFDataTableArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(HFDataTableArray)
|
||||||
|
_sym_db.RegisterMessage(HFDataTableArray.HFDataTableData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,178 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: IndexFutureKLineMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='IndexFutureKLineMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x1dIndexFutureKLineMessage.proto\"\xc0\x02\n\x15IndexFutureKLineArray\x12>\n\tdataArray\x18\x01 \x03(\x0b\x32+.IndexFutureKLineArray.IndexFutureKLineData\x1a\xe6\x01\n\x14IndexFutureKLineData\x12\x15\n\rm_strWindCode\x18\x01 \x02(\t\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x0f\n\x07m_nOpen\x18\x04 \x02(\x01\x12\x0f\n\x07m_nHigh\x18\x05 \x02(\x01\x12\x0e\n\x06m_nLow\x18\x06 \x02(\x01\x12\x10\n\x08m_nClose\x18\x07 \x02(\x01\x12\x11\n\tm_iVolume\x18\x08 \x02(\x03\x12\x12\n\nm_iTurover\x18\t \x02(\x03\x12\x15\n\rm_nMatchItems\x18\n \x02(\x05\x12\x13\n\x0bm_nInterest\x18\x0b \x02(\x05'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_INDEXFUTUREKLINEARRAY_INDEXFUTUREKLINEDATA = _descriptor.Descriptor(
|
||||||
|
name='IndexFutureKLineData',
|
||||||
|
full_name='IndexFutureKLineArray.IndexFutureKLineData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_strWindCode', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_strWindCode', index=0,
|
||||||
|
number=1, type=9, cpp_type=9, label=2,
|
||||||
|
has_default_value=False, default_value=b"".decode('utf-8'),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nOpen', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_nOpen', index=3,
|
||||||
|
number=4, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nHigh', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_nHigh', index=4,
|
||||||
|
number=5, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nLow', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_nLow', index=5,
|
||||||
|
number=6, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nClose', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_nClose', index=6,
|
||||||
|
number=7, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iVolume', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_iVolume', index=7,
|
||||||
|
number=8, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iTurover', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_iTurover', index=8,
|
||||||
|
number=9, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nMatchItems', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_nMatchItems', index=9,
|
||||||
|
number=10, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nInterest', full_name='IndexFutureKLineArray.IndexFutureKLineData.m_nInterest', index=10,
|
||||||
|
number=11, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=124,
|
||||||
|
serialized_end=354,
|
||||||
|
)
|
||||||
|
|
||||||
|
_INDEXFUTUREKLINEARRAY = _descriptor.Descriptor(
|
||||||
|
name='IndexFutureKLineArray',
|
||||||
|
full_name='IndexFutureKLineArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='IndexFutureKLineArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_INDEXFUTUREKLINEARRAY_INDEXFUTUREKLINEDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=34,
|
||||||
|
serialized_end=354,
|
||||||
|
)
|
||||||
|
|
||||||
|
_INDEXFUTUREKLINEARRAY_INDEXFUTUREKLINEDATA.containing_type = _INDEXFUTUREKLINEARRAY
|
||||||
|
_INDEXFUTUREKLINEARRAY.fields_by_name['dataArray'].message_type = _INDEXFUTUREKLINEARRAY_INDEXFUTUREKLINEDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['IndexFutureKLineArray'] = _INDEXFUTUREKLINEARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
IndexFutureKLineArray = _reflection.GeneratedProtocolMessageType('IndexFutureKLineArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'IndexFutureKLineData' : _reflection.GeneratedProtocolMessageType('IndexFutureKLineData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _INDEXFUTUREKLINEARRAY_INDEXFUTUREKLINEDATA,
|
||||||
|
'__module__' : 'IndexFutureKLineMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:IndexFutureKLineArray.IndexFutureKLineData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _INDEXFUTUREKLINEARRAY,
|
||||||
|
'__module__' : 'IndexFutureKLineMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:IndexFutureKLineArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(IndexFutureKLineArray)
|
||||||
|
_sym_db.RegisterMessage(IndexFutureKLineArray.IndexFutureKLineData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,255 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: IndexFutureL1TickMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='IndexFutureL1TickMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x1eIndexFutureL1TickMessage.proto\"\xb5\x04\n\x16IndexFutureL1TickArray\x12@\n\tdataArray\x18\x01 \x03(\x0b\x32-.IndexFutureL1TickArray.IndexFutureL1TickData\x1a\xd8\x03\n\x15IndexFutureL1TickData\x12\x15\n\rm_strWindCode\x18\x01 \x02(\t\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x10\n\x08m_nPrice\x18\x04 \x02(\x01\x12\x11\n\tm_iVolume\x18\x05 \x02(\x03\x12\x12\n\nm_iTurover\x18\x06 \x02(\x03\x12\x15\n\rm_nMatchItems\x18\x07 \x02(\x05\x12\x15\n\rm_chTradeFlag\x18\x08 \x02(\r\x12\x12\n\nm_chBSFlag\x18\t \x02(\r\x12\x14\n\x0cm_iAccVolume\x18\n \x02(\x03\x12\x15\n\rm_iAccTurover\x18\x0b \x02(\x03\x12\x0f\n\x07m_nHigh\x18\x0c \x02(\x01\x12\x0e\n\x06m_nLow\x18\r \x02(\x01\x12\x0f\n\x07m_nOpen\x18\x0e \x02(\x01\x12\x13\n\x0bm_nPreClose\x18\x0f \x02(\x01\x12\x13\n\x0bm_nAskPrice\x18\x10 \x02(\x01\x12\x14\n\x0cm_nAskVolume\x18\x11 \x02(\x05\x12\x13\n\x0bm_nBidPrice\x18\x12 \x02(\x01\x12\x14\n\x0cm_nBidVolume\x18\x13 \x02(\x05\x12\x13\n\x0bm_nPosition\x18\x14 \x02(\x05\x12\x14\n\x0cm_nPreSettle\x18\x15 \x02(\x01\x12\x16\n\x0em_nPrePosition\x18\x16 \x02(\x05'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_INDEXFUTUREL1TICKARRAY_INDEXFUTUREL1TICKDATA = _descriptor.Descriptor(
|
||||||
|
name='IndexFutureL1TickData',
|
||||||
|
full_name='IndexFutureL1TickArray.IndexFutureL1TickData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_strWindCode', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_strWindCode', index=0,
|
||||||
|
number=1, type=9, cpp_type=9, label=2,
|
||||||
|
has_default_value=False, default_value=b"".decode('utf-8'),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPrice', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nPrice', index=3,
|
||||||
|
number=4, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iVolume', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_iVolume', index=4,
|
||||||
|
number=5, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iTurover', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_iTurover', index=5,
|
||||||
|
number=6, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nMatchItems', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nMatchItems', index=6,
|
||||||
|
number=7, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chTradeFlag', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_chTradeFlag', index=7,
|
||||||
|
number=8, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chBSFlag', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_chBSFlag', index=8,
|
||||||
|
number=9, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iAccVolume', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_iAccVolume', index=9,
|
||||||
|
number=10, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iAccTurover', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_iAccTurover', index=10,
|
||||||
|
number=11, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nHigh', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nHigh', index=11,
|
||||||
|
number=12, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nLow', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nLow', index=12,
|
||||||
|
number=13, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nOpen', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nOpen', index=13,
|
||||||
|
number=14, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPreClose', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nPreClose', index=14,
|
||||||
|
number=15, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nAskPrice', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nAskPrice', index=15,
|
||||||
|
number=16, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nAskVolume', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nAskVolume', index=16,
|
||||||
|
number=17, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nBidPrice', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nBidPrice', index=17,
|
||||||
|
number=18, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nBidVolume', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nBidVolume', index=18,
|
||||||
|
number=19, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPosition', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nPosition', index=19,
|
||||||
|
number=20, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPreSettle', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nPreSettle', index=20,
|
||||||
|
number=21, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPrePosition', full_name='IndexFutureL1TickArray.IndexFutureL1TickData.m_nPrePosition', index=21,
|
||||||
|
number=22, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=128,
|
||||||
|
serialized_end=600,
|
||||||
|
)
|
||||||
|
|
||||||
|
_INDEXFUTUREL1TICKARRAY = _descriptor.Descriptor(
|
||||||
|
name='IndexFutureL1TickArray',
|
||||||
|
full_name='IndexFutureL1TickArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='IndexFutureL1TickArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_INDEXFUTUREL1TICKARRAY_INDEXFUTUREL1TICKDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=35,
|
||||||
|
serialized_end=600,
|
||||||
|
)
|
||||||
|
|
||||||
|
_INDEXFUTUREL1TICKARRAY_INDEXFUTUREL1TICKDATA.containing_type = _INDEXFUTUREL1TICKARRAY
|
||||||
|
_INDEXFUTUREL1TICKARRAY.fields_by_name['dataArray'].message_type = _INDEXFUTUREL1TICKARRAY_INDEXFUTUREL1TICKDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['IndexFutureL1TickArray'] = _INDEXFUTUREL1TICKARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
IndexFutureL1TickArray = _reflection.GeneratedProtocolMessageType('IndexFutureL1TickArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'IndexFutureL1TickData' : _reflection.GeneratedProtocolMessageType('IndexFutureL1TickData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _INDEXFUTUREL1TICKARRAY_INDEXFUTUREL1TICKDATA,
|
||||||
|
'__module__' : 'IndexFutureL1TickMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:IndexFutureL1TickArray.IndexFutureL1TickData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _INDEXFUTUREL1TICKARRAY,
|
||||||
|
'__module__' : 'IndexFutureL1TickMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:IndexFutureL1TickArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(IndexFutureL1TickArray)
|
||||||
|
_sym_db.RegisterMessage(IndexFutureL1TickArray.IndexFutureL1TickData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,164 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: IndexKLineMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='IndexKLineMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x17IndexKLineMessage.proto\"\xf3\x01\n\x0fIndexKLineArray\x12\x32\n\tdataArray\x18\x01 \x03(\x0b\x32\x1f.IndexKLineArray.IndexKLineData\x1a\xab\x01\n\x0eIndexKLineData\x12\x0c\n\x04\x63ode\x18\x01 \x02(\x05\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x0f\n\x07m_nOpen\x18\x04 \x02(\x01\x12\x0f\n\x07m_nHigh\x18\x05 \x02(\x01\x12\x0e\n\x06m_nLow\x18\x06 \x02(\x01\x12\x10\n\x08m_nClose\x18\x07 \x02(\x01\x12\x11\n\tm_iVolume\x18\x08 \x02(\x03\x12\x12\n\nm_iTurover\x18\t \x02(\x03'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_INDEXKLINEARRAY_INDEXKLINEDATA = _descriptor.Descriptor(
|
||||||
|
name='IndexKLineData',
|
||||||
|
full_name='IndexKLineArray.IndexKLineData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='code', full_name='IndexKLineArray.IndexKLineData.code', index=0,
|
||||||
|
number=1, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='IndexKLineArray.IndexKLineData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='IndexKLineArray.IndexKLineData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nOpen', full_name='IndexKLineArray.IndexKLineData.m_nOpen', index=3,
|
||||||
|
number=4, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nHigh', full_name='IndexKLineArray.IndexKLineData.m_nHigh', index=4,
|
||||||
|
number=5, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nLow', full_name='IndexKLineArray.IndexKLineData.m_nLow', index=5,
|
||||||
|
number=6, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nClose', full_name='IndexKLineArray.IndexKLineData.m_nClose', index=6,
|
||||||
|
number=7, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iVolume', full_name='IndexKLineArray.IndexKLineData.m_iVolume', index=7,
|
||||||
|
number=8, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iTurover', full_name='IndexKLineArray.IndexKLineData.m_iTurover', index=8,
|
||||||
|
number=9, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=100,
|
||||||
|
serialized_end=271,
|
||||||
|
)
|
||||||
|
|
||||||
|
_INDEXKLINEARRAY = _descriptor.Descriptor(
|
||||||
|
name='IndexKLineArray',
|
||||||
|
full_name='IndexKLineArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='IndexKLineArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_INDEXKLINEARRAY_INDEXKLINEDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=28,
|
||||||
|
serialized_end=271,
|
||||||
|
)
|
||||||
|
|
||||||
|
_INDEXKLINEARRAY_INDEXKLINEDATA.containing_type = _INDEXKLINEARRAY
|
||||||
|
_INDEXKLINEARRAY.fields_by_name['dataArray'].message_type = _INDEXKLINEARRAY_INDEXKLINEDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['IndexKLineArray'] = _INDEXKLINEARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
IndexKLineArray = _reflection.GeneratedProtocolMessageType('IndexKLineArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'IndexKLineData' : _reflection.GeneratedProtocolMessageType('IndexKLineData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _INDEXKLINEARRAY_INDEXKLINEDATA,
|
||||||
|
'__module__' : 'IndexKLineMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:IndexKLineArray.IndexKLineData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _INDEXKLINEARRAY,
|
||||||
|
'__module__' : 'IndexKLineMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:IndexKLineArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(IndexKLineArray)
|
||||||
|
_sym_db.RegisterMessage(IndexKLineArray.IndexKLineData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,185 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: IndexTickMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='IndexTickMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x16IndexTickMessage.proto\"\xb1\x02\n\x0eIndexTickArray\x12\x30\n\tdataArray\x18\x01 \x03(\x0b\x32\x1d.IndexTickArray.IndexTickData\x1a\xec\x01\n\rIndexTickData\x12\x0c\n\x04\x63ode\x18\x01 \x02(\x05\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x10\n\x08m_nPrice\x18\x04 \x02(\x01\x12\x11\n\tm_iVolume\x18\x05 \x02(\x03\x12\x12\n\nm_iTurover\x18\x06 \x02(\x03\x12\x14\n\x0cm_iAccVolume\x18\x07 \x02(\x03\x12\x15\n\rm_iAccTurover\x18\x08 \x02(\x03\x12\x0f\n\x07m_nHigh\x18\t \x02(\x01\x12\x0e\n\x06m_nLow\x18\n \x02(\x01\x12\x0f\n\x07m_nOpen\x18\x0b \x02(\x01\x12\x13\n\x0bm_nPreClose\x18\x0c \x02(\x01'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_INDEXTICKARRAY_INDEXTICKDATA = _descriptor.Descriptor(
|
||||||
|
name='IndexTickData',
|
||||||
|
full_name='IndexTickArray.IndexTickData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='code', full_name='IndexTickArray.IndexTickData.code', index=0,
|
||||||
|
number=1, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='IndexTickArray.IndexTickData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='IndexTickArray.IndexTickData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPrice', full_name='IndexTickArray.IndexTickData.m_nPrice', index=3,
|
||||||
|
number=4, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iVolume', full_name='IndexTickArray.IndexTickData.m_iVolume', index=4,
|
||||||
|
number=5, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iTurover', full_name='IndexTickArray.IndexTickData.m_iTurover', index=5,
|
||||||
|
number=6, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iAccVolume', full_name='IndexTickArray.IndexTickData.m_iAccVolume', index=6,
|
||||||
|
number=7, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iAccTurover', full_name='IndexTickArray.IndexTickData.m_iAccTurover', index=7,
|
||||||
|
number=8, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nHigh', full_name='IndexTickArray.IndexTickData.m_nHigh', index=8,
|
||||||
|
number=9, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nLow', full_name='IndexTickArray.IndexTickData.m_nLow', index=9,
|
||||||
|
number=10, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nOpen', full_name='IndexTickArray.IndexTickData.m_nOpen', index=10,
|
||||||
|
number=11, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPreClose', full_name='IndexTickArray.IndexTickData.m_nPreClose', index=11,
|
||||||
|
number=12, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=96,
|
||||||
|
serialized_end=332,
|
||||||
|
)
|
||||||
|
|
||||||
|
_INDEXTICKARRAY = _descriptor.Descriptor(
|
||||||
|
name='IndexTickArray',
|
||||||
|
full_name='IndexTickArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='IndexTickArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_INDEXTICKARRAY_INDEXTICKDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=27,
|
||||||
|
serialized_end=332,
|
||||||
|
)
|
||||||
|
|
||||||
|
_INDEXTICKARRAY_INDEXTICKDATA.containing_type = _INDEXTICKARRAY
|
||||||
|
_INDEXTICKARRAY.fields_by_name['dataArray'].message_type = _INDEXTICKARRAY_INDEXTICKDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['IndexTickArray'] = _INDEXTICKARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
IndexTickArray = _reflection.GeneratedProtocolMessageType('IndexTickArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'IndexTickData' : _reflection.GeneratedProtocolMessageType('IndexTickData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _INDEXTICKARRAY_INDEXTICKDATA,
|
||||||
|
'__module__' : 'IndexTickMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:IndexTickArray.IndexTickData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _INDEXTICKARRAY,
|
||||||
|
'__module__' : 'IndexTickMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:IndexTickArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(IndexTickArray)
|
||||||
|
_sym_db.RegisterMessage(IndexTickArray.IndexTickData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,171 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: KLineMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='KLineMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x12KLineMessage.proto\"\xf6\x01\n\nKLineArray\x12(\n\tdataArray\x18\x01 \x03(\x0b\x32\x15.KLineArray.KLineData\x1a\xbd\x01\n\tKLineData\x12\x0c\n\x04\x63ode\x18\x01 \x02(\x05\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x0f\n\x07m_nOpen\x18\x04 \x02(\x01\x12\x0f\n\x07m_nHigh\x18\x05 \x02(\x01\x12\x0e\n\x06m_nLow\x18\x06 \x02(\x01\x12\x10\n\x08m_nClose\x18\x07 \x02(\x01\x12\x11\n\tm_iVolume\x18\x08 \x02(\x03\x12\x12\n\nm_iTurover\x18\t \x02(\x03\x12\x15\n\rm_nMatchItems\x18\n \x02(\x05'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_KLINEARRAY_KLINEDATA = _descriptor.Descriptor(
|
||||||
|
name='KLineData',
|
||||||
|
full_name='KLineArray.KLineData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='code', full_name='KLineArray.KLineData.code', index=0,
|
||||||
|
number=1, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='KLineArray.KLineData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='KLineArray.KLineData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nOpen', full_name='KLineArray.KLineData.m_nOpen', index=3,
|
||||||
|
number=4, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nHigh', full_name='KLineArray.KLineData.m_nHigh', index=4,
|
||||||
|
number=5, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nLow', full_name='KLineArray.KLineData.m_nLow', index=5,
|
||||||
|
number=6, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nClose', full_name='KLineArray.KLineData.m_nClose', index=6,
|
||||||
|
number=7, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iVolume', full_name='KLineArray.KLineData.m_iVolume', index=7,
|
||||||
|
number=8, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iTurover', full_name='KLineArray.KLineData.m_iTurover', index=8,
|
||||||
|
number=9, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nMatchItems', full_name='KLineArray.KLineData.m_nMatchItems', index=9,
|
||||||
|
number=10, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=80,
|
||||||
|
serialized_end=269,
|
||||||
|
)
|
||||||
|
|
||||||
|
_KLINEARRAY = _descriptor.Descriptor(
|
||||||
|
name='KLineArray',
|
||||||
|
full_name='KLineArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='KLineArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_KLINEARRAY_KLINEDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=23,
|
||||||
|
serialized_end=269,
|
||||||
|
)
|
||||||
|
|
||||||
|
_KLINEARRAY_KLINEDATA.containing_type = _KLINEARRAY
|
||||||
|
_KLINEARRAY.fields_by_name['dataArray'].message_type = _KLINEARRAY_KLINEDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['KLineArray'] = _KLINEARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
KLineArray = _reflection.GeneratedProtocolMessageType('KLineArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'KLineData' : _reflection.GeneratedProtocolMessageType('KLineData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _KLINEARRAY_KLINEDATA,
|
||||||
|
'__module__' : 'KLineMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:KLineArray.KLineData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _KLINEARRAY,
|
||||||
|
'__module__' : 'KLineMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:KLineArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(KLineArray)
|
||||||
|
_sym_db.RegisterMessage(KLineArray.KLineData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,164 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: OrderMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='OrderMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x12OrderMessage.proto\"\xf8\x01\n\nOrderArray\x12(\n\tdataArray\x18\x01 \x03(\x0b\x32\x15.OrderArray.OrderData\x1a\xbf\x01\n\tOrderData\x12\x0c\n\x04\x63ode\x18\x01 \x02(\x05\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x10\n\x08m_nIndex\x18\x04 \x02(\x05\x12\x10\n\x08m_nOrder\x18\x05 \x02(\x05\x12\x15\n\rm_chOrderKind\x18\x06 \x02(\r\x12\x18\n\x10m_chFunctionCode\x18\x07 \x02(\r\x12\x15\n\rm_nTradePrice\x18\x08 \x02(\x01\x12\x16\n\x0em_nTradeVolume\x18\t \x02(\x05'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_ORDERARRAY_ORDERDATA = _descriptor.Descriptor(
|
||||||
|
name='OrderData',
|
||||||
|
full_name='OrderArray.OrderData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='code', full_name='OrderArray.OrderData.code', index=0,
|
||||||
|
number=1, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='OrderArray.OrderData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='OrderArray.OrderData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nIndex', full_name='OrderArray.OrderData.m_nIndex', index=3,
|
||||||
|
number=4, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nOrder', full_name='OrderArray.OrderData.m_nOrder', index=4,
|
||||||
|
number=5, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chOrderKind', full_name='OrderArray.OrderData.m_chOrderKind', index=5,
|
||||||
|
number=6, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chFunctionCode', full_name='OrderArray.OrderData.m_chFunctionCode', index=6,
|
||||||
|
number=7, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTradePrice', full_name='OrderArray.OrderData.m_nTradePrice', index=7,
|
||||||
|
number=8, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTradeVolume', full_name='OrderArray.OrderData.m_nTradeVolume', index=8,
|
||||||
|
number=9, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=80,
|
||||||
|
serialized_end=271,
|
||||||
|
)
|
||||||
|
|
||||||
|
_ORDERARRAY = _descriptor.Descriptor(
|
||||||
|
name='OrderArray',
|
||||||
|
full_name='OrderArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='OrderArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_ORDERARRAY_ORDERDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=23,
|
||||||
|
serialized_end=271,
|
||||||
|
)
|
||||||
|
|
||||||
|
_ORDERARRAY_ORDERDATA.containing_type = _ORDERARRAY
|
||||||
|
_ORDERARRAY.fields_by_name['dataArray'].message_type = _ORDERARRAY_ORDERDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['OrderArray'] = _ORDERARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
OrderArray = _reflection.GeneratedProtocolMessageType('OrderArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'OrderData' : _reflection.GeneratedProtocolMessageType('OrderData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _ORDERARRAY_ORDERDATA,
|
||||||
|
'__module__' : 'OrderMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:OrderArray.OrderData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _ORDERARRAY,
|
||||||
|
'__module__' : 'OrderMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:OrderArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(OrderArray)
|
||||||
|
_sym_db.RegisterMessage(OrderArray.OrderData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,262 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: TickMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='TickMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x11TickMessage.proto\"\x99\x04\n\tTickArray\x12&\n\tdataArray\x18\x01 \x03(\x0b\x32\x13.TickArray.TickData\x1a\xe3\x03\n\x08TickData\x12\x0c\n\x04\x63ode\x18\x01 \x02(\x05\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x10\n\x08m_nPrice\x18\x04 \x02(\x01\x12\x11\n\tm_iVolume\x18\x05 \x02(\x03\x12\x12\n\nm_iTurover\x18\x06 \x02(\x03\x12\x15\n\rm_nMatchItems\x18\x07 \x02(\x05\x12\x15\n\rm_chTradeFlag\x18\x08 \x02(\r\x12\x12\n\nm_chBSFlag\x18\t \x02(\r\x12\x14\n\x0cm_iAccVolume\x18\n \x02(\x03\x12\x15\n\rm_iAccTurover\x18\x0b \x02(\x03\x12\x0f\n\x07m_nHigh\x18\x0c \x02(\x01\x12\x0e\n\x06m_nLow\x18\r \x02(\x01\x12\x0f\n\x07m_nOpen\x18\x0e \x02(\x01\x12\x13\n\x0bm_nPreClose\x18\x0f \x02(\x01\x12\x13\n\x0bm_nAskPrice\x18\x10 \x03(\x01\x12\x14\n\x0cm_nAskVolume\x18\x11 \x03(\x05\x12\x13\n\x0bm_nBidPrice\x18\x12 \x03(\x01\x12\x14\n\x0cm_nBidVolume\x18\x13 \x03(\x05\x12\x15\n\rm_nAskAvPrice\x18\x14 \x02(\x01\x12\x15\n\rm_nBidAvPrice\x18\x15 \x02(\x01\x12\x19\n\x11m_iTotalAskVolume\x18\x16 \x02(\x03\x12\x19\n\x11m_iTotalBidVolume\x18\x17 \x02(\x03'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_TICKARRAY_TICKDATA = _descriptor.Descriptor(
|
||||||
|
name='TickData',
|
||||||
|
full_name='TickArray.TickData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='code', full_name='TickArray.TickData.code', index=0,
|
||||||
|
number=1, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='TickArray.TickData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='TickArray.TickData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPrice', full_name='TickArray.TickData.m_nPrice', index=3,
|
||||||
|
number=4, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iVolume', full_name='TickArray.TickData.m_iVolume', index=4,
|
||||||
|
number=5, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iTurover', full_name='TickArray.TickData.m_iTurover', index=5,
|
||||||
|
number=6, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nMatchItems', full_name='TickArray.TickData.m_nMatchItems', index=6,
|
||||||
|
number=7, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chTradeFlag', full_name='TickArray.TickData.m_chTradeFlag', index=7,
|
||||||
|
number=8, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chBSFlag', full_name='TickArray.TickData.m_chBSFlag', index=8,
|
||||||
|
number=9, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iAccVolume', full_name='TickArray.TickData.m_iAccVolume', index=9,
|
||||||
|
number=10, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iAccTurover', full_name='TickArray.TickData.m_iAccTurover', index=10,
|
||||||
|
number=11, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nHigh', full_name='TickArray.TickData.m_nHigh', index=11,
|
||||||
|
number=12, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nLow', full_name='TickArray.TickData.m_nLow', index=12,
|
||||||
|
number=13, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nOpen', full_name='TickArray.TickData.m_nOpen', index=13,
|
||||||
|
number=14, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPreClose', full_name='TickArray.TickData.m_nPreClose', index=14,
|
||||||
|
number=15, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nAskPrice', full_name='TickArray.TickData.m_nAskPrice', index=15,
|
||||||
|
number=16, type=1, cpp_type=5, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nAskVolume', full_name='TickArray.TickData.m_nAskVolume', index=16,
|
||||||
|
number=17, type=5, cpp_type=1, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nBidPrice', full_name='TickArray.TickData.m_nBidPrice', index=17,
|
||||||
|
number=18, type=1, cpp_type=5, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nBidVolume', full_name='TickArray.TickData.m_nBidVolume', index=18,
|
||||||
|
number=19, type=5, cpp_type=1, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nAskAvPrice', full_name='TickArray.TickData.m_nAskAvPrice', index=19,
|
||||||
|
number=20, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nBidAvPrice', full_name='TickArray.TickData.m_nBidAvPrice', index=20,
|
||||||
|
number=21, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iTotalAskVolume', full_name='TickArray.TickData.m_iTotalAskVolume', index=21,
|
||||||
|
number=22, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_iTotalBidVolume', full_name='TickArray.TickData.m_iTotalBidVolume', index=22,
|
||||||
|
number=23, type=3, cpp_type=2, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=76,
|
||||||
|
serialized_end=559,
|
||||||
|
)
|
||||||
|
|
||||||
|
_TICKARRAY = _descriptor.Descriptor(
|
||||||
|
name='TickArray',
|
||||||
|
full_name='TickArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='TickArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_TICKARRAY_TICKDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=22,
|
||||||
|
serialized_end=559,
|
||||||
|
)
|
||||||
|
|
||||||
|
_TICKARRAY_TICKDATA.containing_type = _TICKARRAY
|
||||||
|
_TICKARRAY.fields_by_name['dataArray'].message_type = _TICKARRAY_TICKDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['TickArray'] = _TICKARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
TickArray = _reflection.GeneratedProtocolMessageType('TickArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'TickData' : _reflection.GeneratedProtocolMessageType('TickData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _TICKARRAY_TICKDATA,
|
||||||
|
'__module__' : 'TickMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:TickArray.TickData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _TICKARRAY,
|
||||||
|
'__module__' : 'TickMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:TickArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(TickArray)
|
||||||
|
_sym_db.RegisterMessage(TickArray.TickData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,157 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: TickQueueMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='TickQueueMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x16TickQueueMessage.proto\"\xe7\x01\n\x0eTickQueueArray\x12\x30\n\tdataArray\x18\x01 \x03(\x0b\x32\x1d.TickQueueArray.TickQueueData\x1a\xa2\x01\n\rTickQueueData\x12\x0c\n\x04\x63ode\x18\x01 \x02(\x05\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x0f\n\x07m_nSide\x18\x04 \x02(\r\x12\x10\n\x08m_nPrice\x18\x05 \x02(\x01\x12\x15\n\rm_nOrderItems\x18\x06 \x02(\x05\x12\x12\n\nm_nABItems\x18\x07 \x02(\x05\x12\x13\n\x0bm_nABVolume\x18\x08 \x03(\x05'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_TICKQUEUEARRAY_TICKQUEUEDATA = _descriptor.Descriptor(
|
||||||
|
name='TickQueueData',
|
||||||
|
full_name='TickQueueArray.TickQueueData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='code', full_name='TickQueueArray.TickQueueData.code', index=0,
|
||||||
|
number=1, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='TickQueueArray.TickQueueData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='TickQueueArray.TickQueueData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nSide', full_name='TickQueueArray.TickQueueData.m_nSide', index=3,
|
||||||
|
number=4, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nPrice', full_name='TickQueueArray.TickQueueData.m_nPrice', index=4,
|
||||||
|
number=5, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nOrderItems', full_name='TickQueueArray.TickQueueData.m_nOrderItems', index=5,
|
||||||
|
number=6, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nABItems', full_name='TickQueueArray.TickQueueData.m_nABItems', index=6,
|
||||||
|
number=7, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nABVolume', full_name='TickQueueArray.TickQueueData.m_nABVolume', index=7,
|
||||||
|
number=8, type=5, cpp_type=1, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=96,
|
||||||
|
serialized_end=258,
|
||||||
|
)
|
||||||
|
|
||||||
|
_TICKQUEUEARRAY = _descriptor.Descriptor(
|
||||||
|
name='TickQueueArray',
|
||||||
|
full_name='TickQueueArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='TickQueueArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_TICKQUEUEARRAY_TICKQUEUEDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=27,
|
||||||
|
serialized_end=258,
|
||||||
|
)
|
||||||
|
|
||||||
|
_TICKQUEUEARRAY_TICKQUEUEDATA.containing_type = _TICKQUEUEARRAY
|
||||||
|
_TICKQUEUEARRAY.fields_by_name['dataArray'].message_type = _TICKQUEUEARRAY_TICKQUEUEDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['TickQueueArray'] = _TICKQUEUEARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
TickQueueArray = _reflection.GeneratedProtocolMessageType('TickQueueArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'TickQueueData' : _reflection.GeneratedProtocolMessageType('TickQueueData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _TICKQUEUEARRAY_TICKQUEUEDATA,
|
||||||
|
'__module__' : 'TickQueueMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:TickQueueArray.TickQueueData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _TICKQUEUEARRAY,
|
||||||
|
'__module__' : 'TickQueueMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:TickQueueArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(TickQueueArray)
|
||||||
|
_sym_db.RegisterMessage(TickQueueArray.TickQueueData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,178 @@
|
|||||||
|
# -*- coding: utf-8 -*-
|
||||||
|
# Generated by the protocol buffer compiler. DO NOT EDIT!
|
||||||
|
# source: TranseMessage.proto
|
||||||
|
|
||||||
|
from google.protobuf import descriptor as _descriptor
|
||||||
|
from google.protobuf import message as _message
|
||||||
|
from google.protobuf import reflection as _reflection
|
||||||
|
from google.protobuf import symbol_database as _symbol_database
|
||||||
|
# @@protoc_insertion_point(imports)
|
||||||
|
|
||||||
|
_sym_db = _symbol_database.Default()
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
DESCRIPTOR = _descriptor.FileDescriptor(
|
||||||
|
name='TranseMessage.proto',
|
||||||
|
package='',
|
||||||
|
syntax='proto2',
|
||||||
|
serialized_options=None,
|
||||||
|
serialized_pb=b'\n\x13TranseMessage.proto\"\xa8\x02\n\x0bTranseArray\x12*\n\tdataArray\x18\x01 \x03(\x0b\x32\x17.TranseArray.TranseData\x1a\xec\x01\n\nTranseData\x12\x0c\n\x04\x63ode\x18\x01 \x02(\x05\x12\x0f\n\x07m_nDate\x18\x02 \x02(\x05\x12\x0f\n\x07m_nTime\x18\x03 \x02(\x05\x12\x10\n\x08m_nIndex\x18\x04 \x02(\x05\x12\x18\n\x10m_chFunctionCode\x18\x05 \x02(\r\x12\x15\n\rm_chOrderKind\x18\x06 \x02(\r\x12\x12\n\nm_chBSFlag\x18\x07 \x02(\r\x12\x15\n\rm_nTradePrice\x18\x08 \x02(\x01\x12\x16\n\x0em_nTradeVolume\x18\t \x02(\x05\x12\x13\n\x0bm_nAskOrder\x18\n \x02(\x05\x12\x13\n\x0bm_nBidOrder\x18\x0b \x02(\x05'
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
_TRANSEARRAY_TRANSEDATA = _descriptor.Descriptor(
|
||||||
|
name='TranseData',
|
||||||
|
full_name='TranseArray.TranseData',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='code', full_name='TranseArray.TranseData.code', index=0,
|
||||||
|
number=1, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nDate', full_name='TranseArray.TranseData.m_nDate', index=1,
|
||||||
|
number=2, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTime', full_name='TranseArray.TranseData.m_nTime', index=2,
|
||||||
|
number=3, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nIndex', full_name='TranseArray.TranseData.m_nIndex', index=3,
|
||||||
|
number=4, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chFunctionCode', full_name='TranseArray.TranseData.m_chFunctionCode', index=4,
|
||||||
|
number=5, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chOrderKind', full_name='TranseArray.TranseData.m_chOrderKind', index=5,
|
||||||
|
number=6, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_chBSFlag', full_name='TranseArray.TranseData.m_chBSFlag', index=6,
|
||||||
|
number=7, type=13, cpp_type=3, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTradePrice', full_name='TranseArray.TranseData.m_nTradePrice', index=7,
|
||||||
|
number=8, type=1, cpp_type=5, label=2,
|
||||||
|
has_default_value=False, default_value=float(0),
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nTradeVolume', full_name='TranseArray.TranseData.m_nTradeVolume', index=8,
|
||||||
|
number=9, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nAskOrder', full_name='TranseArray.TranseData.m_nAskOrder', index=9,
|
||||||
|
number=10, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='m_nBidOrder', full_name='TranseArray.TranseData.m_nBidOrder', index=10,
|
||||||
|
number=11, type=5, cpp_type=1, label=2,
|
||||||
|
has_default_value=False, default_value=0,
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=84,
|
||||||
|
serialized_end=320,
|
||||||
|
)
|
||||||
|
|
||||||
|
_TRANSEARRAY = _descriptor.Descriptor(
|
||||||
|
name='TranseArray',
|
||||||
|
full_name='TranseArray',
|
||||||
|
filename=None,
|
||||||
|
file=DESCRIPTOR,
|
||||||
|
containing_type=None,
|
||||||
|
fields=[
|
||||||
|
_descriptor.FieldDescriptor(
|
||||||
|
name='dataArray', full_name='TranseArray.dataArray', index=0,
|
||||||
|
number=1, type=11, cpp_type=10, label=3,
|
||||||
|
has_default_value=False, default_value=[],
|
||||||
|
message_type=None, enum_type=None, containing_type=None,
|
||||||
|
is_extension=False, extension_scope=None,
|
||||||
|
serialized_options=None, file=DESCRIPTOR),
|
||||||
|
],
|
||||||
|
extensions=[
|
||||||
|
],
|
||||||
|
nested_types=[_TRANSEARRAY_TRANSEDATA, ],
|
||||||
|
enum_types=[
|
||||||
|
],
|
||||||
|
serialized_options=None,
|
||||||
|
is_extendable=False,
|
||||||
|
syntax='proto2',
|
||||||
|
extension_ranges=[],
|
||||||
|
oneofs=[
|
||||||
|
],
|
||||||
|
serialized_start=24,
|
||||||
|
serialized_end=320,
|
||||||
|
)
|
||||||
|
|
||||||
|
_TRANSEARRAY_TRANSEDATA.containing_type = _TRANSEARRAY
|
||||||
|
_TRANSEARRAY.fields_by_name['dataArray'].message_type = _TRANSEARRAY_TRANSEDATA
|
||||||
|
DESCRIPTOR.message_types_by_name['TranseArray'] = _TRANSEARRAY
|
||||||
|
_sym_db.RegisterFileDescriptor(DESCRIPTOR)
|
||||||
|
|
||||||
|
TranseArray = _reflection.GeneratedProtocolMessageType('TranseArray', (_message.Message,), {
|
||||||
|
|
||||||
|
'TranseData' : _reflection.GeneratedProtocolMessageType('TranseData', (_message.Message,), {
|
||||||
|
'DESCRIPTOR' : _TRANSEARRAY_TRANSEDATA,
|
||||||
|
'__module__' : 'TranseMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:TranseArray.TranseData)
|
||||||
|
})
|
||||||
|
,
|
||||||
|
'DESCRIPTOR' : _TRANSEARRAY,
|
||||||
|
'__module__' : 'TranseMessage_pb2'
|
||||||
|
# @@protoc_insertion_point(class_scope:TranseArray)
|
||||||
|
})
|
||||||
|
_sym_db.RegisterMessage(TranseArray)
|
||||||
|
_sym_db.RegisterMessage(TranseArray.TranseData)
|
||||||
|
|
||||||
|
|
||||||
|
# @@protoc_insertion_point(module_scope)
|
@ -0,0 +1,108 @@
|
|||||||
|
import pymssql
|
||||||
|
import gzip
|
||||||
|
from ProtoBuffEntitys import TickMessage_pb2
|
||||||
|
from ProtoBuffEntitys import OrderMessage_pb2
|
||||||
|
from ProtoBuffEntitys import TranseMessage_pb2
|
||||||
|
from ProtoBuffEntitys import TickQueueMessage_pb2
|
||||||
|
from ProtoBuffEntitys import KLineMessage_pb2
|
||||||
|
|
||||||
|
def ReadTick(ip,user,pw,dbName,code,date):
|
||||||
|
conn = pymssql.connect(host=ip,user=user,password=pw,database=dbName)
|
||||||
|
cursor = conn.cursor()
|
||||||
|
sql = '''SELECT [S_INFO_WINDCODE]
|
||||||
|
,[TRADE_DT]
|
||||||
|
,[Bytes]
|
||||||
|
FROM [{0}].[dbo].[Tick]
|
||||||
|
WHERE [TRADE_DT]='{1}' AND [S_INFO_WINDCODE]='{2}' '''.format(dbName, date,code)
|
||||||
|
cursor.execute(sql)
|
||||||
|
rs = cursor.fetchall()
|
||||||
|
if len(rs) == 0:
|
||||||
|
return []
|
||||||
|
f_all=rs[0][2]
|
||||||
|
f_all=gzip.decompress(f_all)
|
||||||
|
dataArray=TickMessage_pb2.TickArray()
|
||||||
|
dataArray.ParseFromString(f_all)
|
||||||
|
return dataArray.dataArray
|
||||||
|
|
||||||
|
array=ReadTick('10.10.11.61','yuhaomiao','yhm9591','Level2BytesTick','000001.SZ',20200911)
|
||||||
|
print('''Tick Code:{0}'''.format(array[0].code))
|
||||||
|
def ReadTickQue(ip,user,pw,dbName,code,date):
|
||||||
|
conn = pymssql.connect(host=ip,user=user,password=pw,database=dbName)
|
||||||
|
cursor = conn.cursor()
|
||||||
|
sql = '''SELECT [S_INFO_WINDCODE]
|
||||||
|
,[TRADE_DT]
|
||||||
|
,[Bytes]
|
||||||
|
FROM [{0}].[dbo].[TickQue]
|
||||||
|
WHERE [TRADE_DT]='{1}' AND [S_INFO_WINDCODE]='{2}' '''.format(dbName, date,code)
|
||||||
|
cursor.execute(sql)
|
||||||
|
rs = cursor.fetchall()
|
||||||
|
if len(rs) == 0:
|
||||||
|
return []
|
||||||
|
f_all=rs[0][2]
|
||||||
|
f_all=gzip.decompress(f_all)
|
||||||
|
dataArray=TickQueueMessage_pb2.TickQueueArray()
|
||||||
|
dataArray.ParseFromString(f_all)
|
||||||
|
return dataArray.dataArray
|
||||||
|
|
||||||
|
array=ReadTickQue('10.10.11.61','yuhaomiao','yhm9591','Level2BytesTickQue','000001.SZ',20200911)
|
||||||
|
print('''TickQue Code:{0}'''.format(array[0].code))
|
||||||
|
def ReadTranse(ip,user,pw,dbName,code,date):
|
||||||
|
conn = pymssql.connect(host=ip,user=user,password=pw,database=dbName)
|
||||||
|
cursor = conn.cursor()
|
||||||
|
sql = '''SELECT [S_INFO_WINDCODE]
|
||||||
|
,[TRADE_DT]
|
||||||
|
,[Bytes]
|
||||||
|
FROM [{0}].[dbo].[Transe]
|
||||||
|
WHERE [TRADE_DT]='{1}' AND [S_INFO_WINDCODE]='{2}' '''.format(dbName, date,code)
|
||||||
|
cursor.execute(sql)
|
||||||
|
rs = cursor.fetchall()
|
||||||
|
if len(rs) == 0:
|
||||||
|
return []
|
||||||
|
f_all=rs[0][2]
|
||||||
|
f_all=gzip.decompress(f_all)
|
||||||
|
dataArray=TranseMessage_pb2.TranseArray()
|
||||||
|
dataArray.ParseFromString(f_all)
|
||||||
|
return dataArray.dataArray
|
||||||
|
|
||||||
|
array=ReadTranse('10.10.11.61','yuhaomiao','yhm9591','Level2BytesTranse','000001.SZ',20200911)
|
||||||
|
print('''Transe Code:{0}'''.format(array[0].code))
|
||||||
|
def ReadOrder(ip,user,pw,dbName,code,date):
|
||||||
|
conn = pymssql.connect(host=ip,user=user,password=pw,database=dbName)
|
||||||
|
cursor = conn.cursor()
|
||||||
|
sql = '''SELECT [S_INFO_WINDCODE]
|
||||||
|
,[TRADE_DT]
|
||||||
|
,[Bytes]
|
||||||
|
FROM [{0}].[dbo].[Order]
|
||||||
|
WHERE [TRADE_DT]='{1}' AND [S_INFO_WINDCODE]='{2}' '''.format(dbName, date,code)
|
||||||
|
cursor.execute(sql)
|
||||||
|
rs = cursor.fetchall()
|
||||||
|
if len(rs) == 0:
|
||||||
|
return []
|
||||||
|
f_all=rs[0][2]
|
||||||
|
f_all=gzip.decompress(f_all)
|
||||||
|
dataArray=OrderMessage_pb2.OrderArray()
|
||||||
|
dataArray.ParseFromString(f_all)
|
||||||
|
return dataArray.dataArray
|
||||||
|
|
||||||
|
array=ReadOrder('10.10.11.61','yuhaomiao','yhm9591','Level2BytesOrder','000001.SZ',20200911)
|
||||||
|
print('''Order Code:{0}'''.format(array[0].code))
|
||||||
|
def ReadKLine(ip,user,pw,dbName,code,date):
|
||||||
|
conn = pymssql.connect(host=ip,user=user,password=pw,database=dbName)
|
||||||
|
cursor = conn.cursor()
|
||||||
|
sql = '''SELECT [S_INFO_WINDCODE]
|
||||||
|
,[TRADE_DT]
|
||||||
|
,[Bytes]
|
||||||
|
FROM [{0}].[dbo].[KLine]
|
||||||
|
WHERE [TRADE_DT]='{1}' AND [S_INFO_WINDCODE]='{2}' '''.format(dbName, date,code)
|
||||||
|
cursor.execute(sql)
|
||||||
|
rs = cursor.fetchall()
|
||||||
|
if len(rs) == 0:
|
||||||
|
return []
|
||||||
|
f_all=rs[0][2]
|
||||||
|
f_all=gzip.decompress(f_all)
|
||||||
|
dataArray=KLineMessage_pb2.KLineArray()
|
||||||
|
dataArray.ParseFromString(f_all)
|
||||||
|
return dataArray.dataArray
|
||||||
|
|
||||||
|
array=ReadKLine('10.10.11.61','yuhaomiao','yhm9591','Level2BytesKLine','000001.SZ',20200911)
|
||||||
|
print('''KLine Code:{0}'''.format(array[0].code))
|
@ -0,0 +1,12 @@
|
|||||||
|
n=1000000
|
||||||
|
date=take(2006.01.01..2006.01.31, n);
|
||||||
|
x=rand(10.0, n);
|
||||||
|
t=table(date, x);
|
||||||
|
|
||||||
|
login("admin","123456")
|
||||||
|
db=database("dfs://valuedb", VALUE, 2006.01.01..2006.01.31)
|
||||||
|
pt = db.createPartitionedTable(t, `pt, `date);
|
||||||
|
pt.append!(t);
|
||||||
|
|
||||||
|
pt=loadTable("dfs://valuedb","pt")
|
||||||
|
select top 100 * from pt
|
@ -0,0 +1 @@
|
|||||||
|
db=database("dfs://L2_ORDER", VALUE, 2019.01.01..2022.01.31)
|
@ -0,0 +1,13 @@
|
|||||||
|
symbol = take(`AAPL, 6) join take(`FB, 5)
|
||||||
|
time = 2019.02.27T09:45:01.000000000 + [146, 278, 412, 445, 496, 789, 212, 556, 598, 712, 989]
|
||||||
|
price=173.27 173.26 173.24 173.25 173.26 173.27 161.51 161.50 161.49 161.50 161.51
|
||||||
|
quotes=table(symbol, time, price)
|
||||||
|
print(quotes)
|
||||||
|
|
||||||
|
weights = dict(`AAPL`FB, 0.6 0.4)
|
||||||
|
print(weights)
|
||||||
|
|
||||||
|
ETF = select symbol, time, price*weights[symbol] as price from quotes;
|
||||||
|
print(ETF)
|
||||||
|
|
||||||
|
select rowSum(ffill(last(price))) from ETF pivot by time, symbol;
|
@ -0,0 +1,10 @@
|
|||||||
|
|
||||||
|
login('admin', '123456')
|
||||||
|
|
||||||
|
tt = table(100:0, `code`m_nDate`m_nTime`m_nSide`m_nPrice`m_nOrderItems`m_nABItems`m_nABVolume, [SYMBOL, DATE, TIME, INT, FLOAT, INT, INT, INT[]])
|
||||||
|
|
||||||
|
share t as gt
|
||||||
|
|
||||||
|
share tt as gtt
|
||||||
|
|
||||||
|
dropStreamTable(gt)
|
@ -0,0 +1,5 @@
|
|||||||
|
|
||||||
|
login("admin","123456")
|
||||||
|
pt=loadTable("dfs://valuedb","pt")
|
||||||
|
getTabletsMeta("/valuedb/%", `pt, true);
|
||||||
|
select top 100 * from pt
|
@ -0,0 +1,94 @@
|
|||||||
|
import importlib
|
||||||
|
import gzip
|
||||||
|
import pickle
|
||||||
|
from pprint import pprint
|
||||||
|
from tqdm import tqdm
|
||||||
|
|
||||||
|
import numpy as np
|
||||||
|
import pandas as pd
|
||||||
|
|
||||||
|
import dolphindb as ddb
|
||||||
|
import dolphindb.settings as keys
|
||||||
|
|
||||||
|
import sqlalchemy as sa
|
||||||
|
|
||||||
|
import ProtoBuffEntitys
|
||||||
|
|
||||||
|
|
||||||
|
def main():
|
||||||
|
from ProtoBuffEntitys import TickQueueMessage_pb2
|
||||||
|
engine = sa.create_engine(
|
||||||
|
"mssql+pyodbc://{username}:{password}@{host}/master?driver=ODBC+Driver+18+for+SQL+Server".format(**DDBLoader.mssql_config),
|
||||||
|
connect_args = {
|
||||||
|
"TrustServerCertificate": "yes"
|
||||||
|
}, echo=False
|
||||||
|
)
|
||||||
|
|
||||||
|
s = ddb.session(DDBLoader.ddb_config['host'], 8848)
|
||||||
|
s.login(DDBLoader.ddb_config['username'], DDBLoader.ddb_config['password'])
|
||||||
|
|
||||||
|
with engine.connect() as conn:
|
||||||
|
stat = "select top 1 * from Level2BytesTickQue.dbo.TickQue"
|
||||||
|
rs = conn.execute(stat)
|
||||||
|
|
||||||
|
for row in rs.fetchall():
|
||||||
|
print(type(row))
|
||||||
|
blob = gzip.decompress(row[2])
|
||||||
|
dataArray = TickQueueMessage_pb2.TickQueueArray()
|
||||||
|
dataArray.ParseFromString(blob)
|
||||||
|
|
||||||
|
data_dict_list = [
|
||||||
|
{field.name : val for field, val in entry.ListFields()}
|
||||||
|
for entry in dataArray.dataArray
|
||||||
|
]
|
||||||
|
|
||||||
|
df = pd.DataFrame(data_dict_list)
|
||||||
|
df['code'] = make_symbol(df['code'])
|
||||||
|
df['m_nDate'] = make_date(df['m_nDate'])
|
||||||
|
df['m_nTime'] = df['m_nDate'] + make_time(df['m_nTime'])
|
||||||
|
df['m_nABVolume'] = make_nparray(df['m_nABVolume'])
|
||||||
|
|
||||||
|
pprint(df[['code', 'm_nDate', 'm_nTime']].head())
|
||||||
|
|
||||||
|
s.upload({'tb' : df})
|
||||||
|
res = s.run("typestr(tb)")
|
||||||
|
pprint(res)
|
||||||
|
|
||||||
|
stat = """
|
||||||
|
syms = symbol(exec code from tb)
|
||||||
|
replaceColumn!(tb, `code, syms)
|
||||||
|
"""
|
||||||
|
res = s.run(stat)
|
||||||
|
pprint(res)
|
||||||
|
pprint(s.run("schema(tb).colDefs"))
|
||||||
|
|
||||||
|
res = s.run("append!(gtt, tb)")
|
||||||
|
s.undef("tb", "VAR")
|
||||||
|
|
||||||
|
print(res)
|
||||||
|
break
|
||||||
|
|
||||||
|
|
||||||
|
def main2():
|
||||||
|
loader = DDBLoader()
|
||||||
|
#pprint(loader.mssql_name_dict)
|
||||||
|
|
||||||
|
stock_list, date_list = loader.get_stock_date_list(True)
|
||||||
|
print('Did get stock list and date list from mssql')
|
||||||
|
#pprint(date_list[:5])
|
||||||
|
#pprint(stock_list[:5])
|
||||||
|
|
||||||
|
loader.create_ddb_database(stock_list, date_list)
|
||||||
|
print('Did create ddb database')
|
||||||
|
|
||||||
|
for type_name in loader.hft_type_list:
|
||||||
|
loader.create_ddb_partition_table(type_name)
|
||||||
|
print(f"Did create ddb table for {type_name}")
|
||||||
|
|
||||||
|
loader.do_load_from_mssql(type_name, stock_list[0], date_list[0])
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
main3()
|
||||||
|
|
@ -0,0 +1,47 @@
|
|||||||
|
/**
|
||||||
|
stcokMarketReplay.txt
|
||||||
|
Script to replay stock market data
|
||||||
|
DolphinDB Inc.
|
||||||
|
DolphinDB server version: 2.00.6 2022.05.31
|
||||||
|
Storage engine: TSDB
|
||||||
|
Last modification time: 2022.07.07
|
||||||
|
*/
|
||||||
|
|
||||||
|
//login account
|
||||||
|
login("admin", "123456")
|
||||||
|
|
||||||
|
//create stream table: messageStream
|
||||||
|
def createStreamTableFunc(){
|
||||||
|
colName = `msgTime`msgType`msgBody
|
||||||
|
colType = [TIMESTAMP,SYMBOL, BLOB]
|
||||||
|
messageTemp = streamTable(1000000:0, colName, colType)
|
||||||
|
enableTableShareAndPersistence(table=messageTemp, tableName="messageStream", asynWrite=true, compress=true, cacheSize=1000000, retentionMinutes=1440, flushMode=0, preCache=10000)
|
||||||
|
messageTemp = NULL
|
||||||
|
}
|
||||||
|
createStreamTableFunc()
|
||||||
|
go
|
||||||
|
|
||||||
|
//replay history data
|
||||||
|
def replayStockMarketData(){
|
||||||
|
timeRS = cutPoints(09:15:00.000..15:00:00.000, 100)
|
||||||
|
orderDS = replayDS(sqlObj=<select * from loadTable("dfs://order", "order") where Date = 2020.12.31>, dateColumn=`Date, timeColumn=`Time, timeRepartitionSchema=timeRS)
|
||||||
|
tradeDS = replayDS(sqlObj=<select * from loadTable("dfs://trade", "trade") where Date = 2020.12.31>, dateColumn=`Date, timeColumn=`Time, timeRepartitionSchema=timeRS)
|
||||||
|
snapshotDS = replayDS(sqlObj=<select * from loadTable("dfs://snapshot", "snapshot") where Date =2020.12.31>, dateColumn=`Date, timeColumn=`Time, timeRepartitionSchema=timeRS)
|
||||||
|
inputDict = dict(["order", "trade", "snapshot"], [orderDS, tradeDS, snapshotDS])
|
||||||
|
|
||||||
|
submitJob("replay", "replay stock market", replay, inputDict, messageStream, `Date, `Time, , , 3)
|
||||||
|
}
|
||||||
|
replayStockMarketData()
|
||||||
|
|
||||||
|
getRecentJobs()
|
||||||
|
|
||||||
|
////load text and replay memory table
|
||||||
|
//def loadTextAndReplay(){
|
||||||
|
// orderTable= select * from loadText("/yourDataPath/replayData/order.csv") order by Time
|
||||||
|
// tradeTable = select * from loadText("/yourDataPath/replayData/trade.csv") order by Time
|
||||||
|
// snapshotTable = select * from loadText("/yourDataPath/replayData/snapshot.csv") order by Time
|
||||||
|
// inputDict = dict(["order", "trade", "snapshot"], [orderTable, tradeTable, snapshotTable])
|
||||||
|
//
|
||||||
|
// submitJob("replay", "replay memory table", replay, inputDict, messageStream, `Date, `Time, , , 1)
|
||||||
|
//}
|
||||||
|
//loadCSVAndReplay()
|
Loading…
Reference in new issue