In [ ]:

    

# 600000.SH Minute Kline in emquant with ChanTrendHandler V3.0

import os
from pymongo import MongoClient

def get_code_from_colname(colname):
    (market, code) = colname.split('_')
    return code + '.' + market

wind_db_name = os.environ.get('WIND_DB', 'emquant')
chan_db_name = os.environ.get('CHAN_DB', 'emchantest')
db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.21')
db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

# wind_db_name = os.environ.get('WIND_DB', 'wind')
# chan_db_name = os.environ.get('CHAN_DB', 'chan')
# db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.103')
# db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

client = MongoClient(db_ip, db_port)
db_wind = client[wind_db_name]
db_chan = client[chan_db_name]

chankline_col = db_chan['chankline']

code_list = db_wind.collection_names(include_system_collections=False)
code_list = [get_code_from_colname(code) for code in code_list if 'SH' in code or 'SZ' in code]

print('--- Chan Kline ---')
cur = db_chan['chankline'].find().sort('index', -1)
print('167999: {}'.format(cur.count()))
print('167998: {}'.format(cur[0]['index']))

print('--- Chan Fractal ---')
cur = db_chan['fractal'].find().sort('index', -1)
print('29028: {}'.format(cur.count()))
print('29027: {}'.format(cur[0]['index']))

print('--- Chan Bi ---')
cur = db_chan['trend'].find({'level': '-1'}).sort('index', -1)
print('5893: {}'.format(cur.count()))
print('5892: {}'.format(cur[0]['index']))

print('--- Chan Duan ---')
cur = db_chan['trend'].find({'level': '0'}).sort('index', -1)
print('804: {}'.format(cur.count()))
print('803: {}'.format(cur[0]['index']))

print('--- Chan Bi Centre ---')
cur = db_chan['centre'].find({'level': '-1'}).sort('index', -1)
print('1328: {}'.format(cur.count()))
print('1327: {}'.format(cur[0]['index']))

print('--- Level 1 ---')
cur = db_chan['trend'].find({'level': '1'}).sort('index', -1)
print('120: {}'.format(cur.count()))
print('119: {}'.format(cur[0]['index']))

print('--- Duan Centre ---')
cur = db_chan['centre'].find({'level': '0'}).sort('index', -1)
print('188: {}'.format(cur.count()))
print('187: {}'.format(cur[0]['index']))

print('--- Level 2 ---')
cur = db_chan['trend'].find({'level': '2'}).sort('index', -1)
print('10: {}'.format(cur.count()))
print('9: {}'.format(cur[0]['index']))

print('--- Level 1 Centre ---')
cur = db_chan['centre'].find({'level': '1'}).sort('index', -1)
print('26: {}'.format(cur.count()))
print('25: {}'.format(cur[0]['index']))


    

In [ ]:

    

# 600000.SH Minute Kline in emquant with ChanTrendHandler V2.0 and previous Duan logic for duan

import os
from pymongo import MongoClient

def get_code_from_colname(colname):
    (market, code) = colname.split('_')
    return code + '.' + market

wind_db_name = os.environ.get('WIND_DB', 'emquant')
chan_db_name = os.environ.get('CHAN_DB', 'emchantest')
db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.21')
db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

# wind_db_name = os.environ.get('WIND_DB', 'wind')
# chan_db_name = os.environ.get('CHAN_DB', 'chan')
# db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.103')
# db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

client = MongoClient(db_ip, db_port)
db_wind = client[wind_db_name]
db_chan = client[chan_db_name]

chankline_col = db_chan['chankline']

code_list = db_wind.collection_names(include_system_collections=False)
code_list = [get_code_from_colname(code) for code in code_list if 'SH' in code or 'SZ' in code]

print('--- Chan Kline ---')
cur = db_chan['chankline'].find().sort('index', -1)
print('167999: {}'.format(cur.count()))
print('167998: {}'.format(cur[0]['index']))

print('--- Chan Fractal ---')
cur = db_chan['fractal'].find().sort('index', -1)
print('29028: {}'.format(cur.count()))
print('29027: {}'.format(cur[0]['index']))

print('--- Chan Bi ---')
cur = db_chan['trend'].find({'level': '-1'}).sort('index', -1)
print('5893: {}'.format(cur.count()))
print('5892: {}'.format(cur[0]['index']))

print('--- Chan Duan ---')
cur = db_chan['trend'].find({'level': '0'}).sort('index', -1)
print('804: {}'.format(cur.count()))
print('803: {}'.format(cur[0]['index']))

print('--- Chan Bi Centre ---')
cur = db_chan['centre'].find({'level': '-1'}).sort('index', -1)
print('1292: {}'.format(cur.count()))
print('1291: {}'.format(cur[0]['index']))

print('--- Level 1 ---')
cur = db_chan['trend'].find({'level': '1'}).sort('index', -1)
print('60: {}'.format(cur.count()))
print('59: {}'.format(cur[0]['index']))

print('--- Duan Centre ---')
cur = db_chan['centre'].find({'level': '0'}).sort('index', -1)
print('138: {}'.format(cur.count()))
print('137: {}'.format(cur[0]['index']))


    

In [ ]:

    

# 600000.SH Minute Kline in emquant with ChanTrendHandler V2.0

import os
from pymongo import MongoClient

def get_code_from_colname(colname):
    (market, code) = colname.split('_')
    return code + '.' + market

wind_db_name = os.environ.get('WIND_DB', 'emquant')
chan_db_name = os.environ.get('CHAN_DB', 'emchantest')
db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.21')
db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

# wind_db_name = os.environ.get('WIND_DB', 'wind')
# chan_db_name = os.environ.get('CHAN_DB', 'chan')
# db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.103')
# db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

client = MongoClient(db_ip, db_port)
db_wind = client[wind_db_name]
db_chan = client[chan_db_name]

chankline_col = db_chan['chankline']

code_list = db_wind.collection_names(include_system_collections=False)
code_list = [get_code_from_colname(code) for code in code_list if 'SH' in code or 'SZ' in code]

print('--- Chan Kline ---')
cur = db_chan['chankline'].find().sort('index', -1)
print('167999: {}'.format(cur.count()))
print('167998: {}'.format(cur[0]['index']))

print('--- Chan Fractal ---')
cur = db_chan['fractal'].find().sort('index', -1)
print('29028: {}'.format(cur.count()))
print('29027: {}'.format(cur[0]['index']))

print('--- Chan Bi ---')
cur = db_chan['trend'].find({'level': '-1'}).sort('index', -1)
print('5893: {}'.format(cur.count()))
print('5892: {}'.format(cur[0]['index']))

print('--- Chan Duan ---')
cur = db_chan['trend'].find({'level': '0'}).sort('index', -1)
print('398: {}'.format(cur.count()))
print('397: {}'.format(cur[0]['index']))

print('--- Chan Bi Centre ---')
cur = db_chan['centre'].find({'level': '-1'}).sort('index', -1)
print('982: {}'.format(cur.count()))
print('981: {}'.format(cur[0]['index']))

print('--- Level 1 ---')
cur = db_chan['trend'].find({'level': '1'}).sort('index', -1)
print('28: {}'.format(cur.count()))
print('27: {}'.format(cur[0]['index']))

print('--- Duan Centre ---')
cur = db_chan['centre'].find({'level': '0'}).sort('index', -1)
print('63: {}'.format(cur.count()))
print('62: {}'.format(cur[0]['index']))


    

In [ ]:

    

# 600000.SH Minute Kline in emquant

import os
from pymongo import MongoClient

def get_code_from_colname(colname):
    (market, code) = colname.split('_')
    return code + '.' + market

wind_db_name = os.environ.get('WIND_DB', 'emquant')
chan_db_name = os.environ.get('CHAN_DB', 'emchantest')
db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.21')
db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

# wind_db_name = os.environ.get('WIND_DB', 'wind')
# chan_db_name = os.environ.get('CHAN_DB', 'chan')
# db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.103')
# db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

client = MongoClient(db_ip, db_port)
db_wind = client[wind_db_name]
db_chan = client[chan_db_name]

chankline_col = db_chan['chankline']

code_list = db_wind.collection_names(include_system_collections=False)
code_list = [get_code_from_colname(code) for code in code_list if 'SH' in code or 'SZ' in code]

print('--- Chan Kline ---')
cur = db_chan['chankline'].find().sort('index', -1)
print('167999: {}'.format(cur.count()))
print('167998: {}'.format(cur[0]['index']))

print('--- Chan Fractal ---')
cur = db_chan['fractal'].find().sort('index', -1)
print('29028: {}'.format(cur.count()))
print('29027: {}'.format(cur[0]['index']))

print('--- Chan Bi ---')
cur = db_chan['trend'].find({'level': '-1'}).sort('index', -1)
print('5893: {}'.format(cur.count()))
print('5892: {}'.format(cur[0]['index']))

print('--- Chan Duan ---')
cur = db_chan['trend'].find({'level': '0'}).sort('index', -1)
print('804: {}'.format(cur.count()))
print('803: {}'.format(cur[0]['index']))

print('--- Chan Bi Centre ---')
cur = db_chan['centre'].find({'level': '-1'}).sort('index', -1)
print('1328: {}'.format(cur.count()))
print('1327: {}'.format(cur[0]['index']))


    

In [ ]:

    

# 600000.SH Day Kline in emquant

import os
from pymongo import MongoClient

def get_code_from_colname(colname):
    (market, code) = colname.split('_')
    return code + '.' + market

wind_db_name = os.environ.get('WIND_DB', 'emquant')
chan_db_name = os.environ.get('CHAN_DB', 'emchantest')
db_ip = os.environ.get('MONGO_DB_IP_ADDR', '172.17.0.1')
db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

# wind_db_name = os.environ.get('WIND_DB', 'wind')
# chan_db_name = os.environ.get('CHAN_DB', 'chan')
# db_ip = os.environ.get('MONGO_DB_IP_ADDR', '192.168.1.103')
# db_port = int(os.environ.get('MONGO_DB_PORT', 27017))

client = MongoClient(db_ip, db_port)
db_wind = client[wind_db_name]
db_chan = client[chan_db_name]

chankline_col = db_chan['chankline']

code_list = db_wind.collection_names(include_system_collections=False)
code_list = [get_code_from_colname(code) for code in code_list if 'SH' in code or 'SZ' in code]

print('--- Chan Kline ---')
cur = db_chan['chankline'].find().sort('index', -1)
print('733: {}'.format(cur.count()))
print('732: {}'.format(cur[0]['index']))

print('--- Chan Fractal ---')
cur = db_chan['fractal'].find().sort('index', -1)
print('243: {}'.format(cur.count()))
print('242: {}'.format(cur[0]['index']))

print('--- Chan Bi ---')
cur = db_chan['trend'].find({'level': '-1'}).sort('index', -1)
print('44: {}'.format(cur.count()))
print('43: {}'.format(cur[0]['index']))

print('--- Chan Duan ---')
cur = db_chan['trend'].find({'level': '0'}).sort('index', -1)
print('8: {}'.format(cur.count()))
print('7: {}'.format(cur[0]['index']))

print('--- Chan Bi Centre ---')
cur = db_chan['centre'].find({'level': '-1'}).sort('index', -1)
print('14: {}'.format(cur.count()))
print('13: {}'.format(cur[0]['index']))