from flask import Flask, jsonify



# 最基本的测试



app =Flask(__name__)





@app.route('/about')

def about():

    return 'this is about page'



@app.route('/404')

def error_handle():

    return '404 error'



@app.route('/')

def error_handle():

    return jsonify({'code':100})







if __name__=='__main__':

    app.run(host='0.0.0.0',port=8001,debug=True)

 26 2022-07-15T02:15:09.595Z In(05) host-7426 /tmp/modconfig-PB4afO/vmmon-only/./include/vm_assert.h:372:22: note: in definition of macro ‘ASSERT_ON_COMPILE’

     25 2022-07-15T02:15:09.595Z In(05) host-7426   372 |       _Static_assert(e, #e); \

     24 2022-07-15T02:15:09.595Z In(05) host-7426       |                      ^

     23 2022-07-15T02:15:09.595Z In(05) host-7426 /tmp/modconfig-PB4afO/vmmon-only/./include/vm_asm_x86.h:215:7: note: in expansion of macro ‘ASSERT_ON_COMPILE_SELECTOR_SIZE’

     22 2022-07-15T02:15:09.595Z In(05) host-7426   215 |       ASSERT_ON_COMPILE_SELECTOR_SIZE(expr);                           \

     21 2022-07-15T02:15:09.595Z In(05) host-7426       |       ^~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

     20 2022-07-15T02:15:09.595Z In(05) host-7426 /tmp/modconfig-PB4afO/vmmon-only/./include/vm_asm_x86.h:227:22: note: in expansion of macro ‘SET_SEGREG’

     19 2022-07-15T02:15:09.595Z In(05) host-7426   227 | #define SET_GS(expr) SET_SEGREG(gs, expr)

     18 2022-07-15T02:15:09.595Z In(05) host-7426       |                      ^~~~~~~~~~

     17 2022-07-15T02:15:09.595Z In(05) host-7426 /tmp/modconfig-PB4afO/vmmon-only/common/task.c:2726:10: note: in expansion of macro ‘SET_GS’

     16 2022-07-15T02:15:09.595Z In(05) host-7426  2726 |          SET_GS(gs);

     15 2022-07-15T02:15:09.595Z In(05) host-7426       |          ^~~~~~

     14 2022-07-15T02:15:09.595Z In(05) host-7426 make[2]: *** [scripts/Makefile.build:285: /tmp/modconfig-PB4afO/vmmon-only/common/task.o] Error 1

     13 2022-07-15T02:15:09.595Z In(05) host-7426 make[2]: *** Waiting for unfinished jobs....

     12 2022-07-15T02:15:09.595Z In(05) host-7426 make[1]: *** [Makefile:1875: /tmp/modconfig-PB4afO/vmmon-only] Error 2

     11 2022-07-15T02:15:09.595Z In(05) host-7426 make: *** [Makefile:117: vmmon.ko] Error 2

     10 2022-07-15T02:15:09.595Z In(05) host-7426 Using kernel build system.

      9 2022-07-15T02:15:09.595Z In(05) host-7426 /tmp/modconfig-PB4afO/vmnet-only/driver.c: In function ‘VNetFileOpUnlockedIoctl’:

      8 2022-07-15T02:15:09.595Z In(05) host-7426 /tmp/modconfig-PB4afO/vmnet-only/driver.c:966:7: warning: this statement may fall through [-Wimplicit-fallthrough=]

      7 2022-07-15T02:15:09.595Z In(05) host-7426   966 |       {

      6 2022-07-15T02:15:09.595Z In(05) host-7426       |       ^

      5 2022-07-15T02:15:09.595Z In(05) host-7426 /tmp/modconfig-PB4afO/vmnet-only/driver.c:976:4: note: here

      4 2022-07-15T02:15:09.595Z In(05) host-7426   976 |    case SIOCGETAPIVERSION:

      3 2022-07-15T02:15:09.595Z In(05) host-7426       |    ^~~~

      2 2022-07-15T02:15:09.595Z In(05) host-7426 Skipping BTF generation for /tmp/modconfig-PB4afO/vmnet-only/vmnet.ko due to unavailability of vmlinux

      1 2022-07-15T02:15:09.595Z In(05) host-7426 Unable to install all modules.  See log for details.

   host-7426 Skipping BTF generation for /tmp/modconfig-PB4afO/vmnet-only/vmnet.ko due to unavailability of vmlinux

    

    host-7426 Unable to install all modules.  See log for details

unzip w16.2.3-k5.17.zip

    INSTALL  

    LICENSE  

    Makefile  

    README  

    vmmon-only    

    vmnet-only  

vmmon-only    

vmnet-only  

    tar -cf vmmon.tar vmmon-only

    tar -cf vmnet.tar vmnet-only

sudo cp -v vmmon.tar vmnet.tar /usr/lib/vmware/modules/source/

sudo vmware-modconfig --console --install-all

#!/bin/bash

line=$(ps -aux | grep -c /usr/sbin/ssh | grep -v "grep") 

# 匹配的行数

if [ $line -eq 1 ];

then        

sudo /etc/init.d/ssh restart   

# 重启ssh服务

else        

echo ssh is running....  

# 向日志发送邮件，显示ssh运行中。。。

fi

UPDATE wp_posts set post_content = REPLACE(post_content,"crop.png","hxxy-resize.png") where post_content like '%crop.png%';

1.交易佣金是多少？



A股万分之二点五，最低五元手续费；

货币类ETF买卖和申赎均无费用；

场内基金只能买卖不能申赎，交易费用根据客户交易佣金来定，有最低5元限制；

具体情况请联系一创咨询；

2.平台支持的交易频率是多少？



支持「每分」和「每天」两个交易频率

3.平台支持的交易品种有哪些？



目前支持A股、场内基金。

4.可以同时跑几个实盘策略？



目前每个用户可以运行1个实盘策略，需要更多权限请联系自己的客户经理申请。

5.其他问题如何咨询？



查看常见问题及实盘说明文档

点击聚宽官网的在线客服免费咨询

6.请问实盘支持哪些系统

请您使用win7、8、9、10系统和mac系统进行实盘账户的绑定操作。目前暂时不支持win xp等系统和虚拟机。

    def query_offset(self,start,count):

        sqlite_str = 'select code,open,current from {} limit {},{}'.format(self.table_name,start,count)

        cursor = self.db.cursor()

        with lock:

            try:

                cursor.execute(sqlite_str)

            except Exception as e:

                log.info(e)

                self.db.rollback()

            else:

                return cursor.fetchall()

$ aria2c 

https: //openresty.org/download/openresty-1.21.4.1-win64.zip





07/10 10:58:58 [NOTICE] Downloading 1 item(s)



07/10 10:58:58 [ERROR] CUID#7 - Download aborted. URI=https: //openresty.org/download/openresty-1.21.4.1-win64.zip

Exception: [AbstractCommand.cc:351] errorCode=1 URI=https: //openresty.org/download/openresty-1.21.4.1-win64.zip

  -> [InitiateConnectionCommandFactory.cc:87] errorCode=1 https is not supported yet.



07/10 10:58:58 [NOTICE] Download GID#b9bc95619990e7e4 not complete: 



Download Results:

gid   |stat|avg speed  |path/URI

======+====+===========+=======================================================

b9bc95|ERR |        n/a|

https: //openresty.org/download/openresty-1.21.4.1-win64.zip





http: //openresty.org/download/openresty-1.21.4.1-win64.zip



Status Legend:

(ERR):error occurred.



aria2 will resume download if the transfer is restarted.

If there are any errors, then see the log file. See '-l' option in help/man page for details.

./configure --with-openssl

make && sudo make install

import datetime

import random

import sqlite3

import threading

import logging as log

import time



lock = threading.Lock()

class SQLiteDBCls:



    def __init__(self, cache=True):

        _type = ":memory:"



        self.db = sqlite3.connect(_type, check_same_thread=False)



        self.table_name = 'tick_data'



    def create_index(self):



        cmd = 'CREATE INDEX code_ix ON {} (current)'.format(self.table_name)

        with lock:

            try:



                cursor = self.db.cursor()

                cursor.execute(cmd)

            except Exception as e:

                log.info(e)

                self.db.rollback()

            else:

                self.db.commit()



    def create_table(self):

        # cursor = self.db.cursor()

        cmd = 'create table if not exists {} (id INTEGER PRIMARY KEY AUTOINCREMENT,code text,open double,current time)'.format(

            self.table_name)

        with lock:

            try:

                cursor = self.db.cursor()

                cursor.execute(cmd)

            except Exception as e:

                log.info(e)

                self.db.rollback()

            else:

                self.db.commit()



    def add(self, code, price, t):

        cmd = 'insert into {} (code,open,current) values (?,?,?);'.format(self.table_name)

        with lock:

            try:

                cursor = self.db.cursor()

                cursor.execute(cmd, (code, price, t))

            except Exception as e:

                log.info(e)

                self.db.rollback()

            else:

                self.db.commit()



    def batch_add(self, data):



        # 批量加入

        print('===========',threading.current_thread().getName())

        # log.info(threading.current_thread().getName())

        cmd = 'insert into {} (code,open,current) values (?,?,?)'.format(self.table_name)

        with lock:

            try:

                cursor = self.db.cursor()

                cursor.executemany(cmd, data)

            except Exception as e:

                log.info(e)

                self.db.rollback()

            else:

                self.db.commit()



    def result(self):

        cmd = 'select count(*) from `{}`'.format(self.table_name)



        with lock:



            try:

                cursor = self.db.cursor()

                cursor.execute(cmd)

            except Exception as e:

                log.info(e)

                self.db.rollback()

            else:

                return cursor.fetchone()



 

def data_gen():

    minute = 6000

    code = ['123011.SS','110010.SS','112111.SS']

    for i in range(minute):

        current = (datetime.datetime.now()+datetime.timedelta(minutes=i)).strftime('%H:%M:%D')

        data_list =

        for c in code:

            price = 5+random.random()+120

            data = (c,price,current)

            data_list.append(data)

        yield data_list

        # time.sleep(0.5)



app = SQLiteDBCls(cache=True)

app.create_table()

app.create_index()



def data_validation():

    print(app.result())

    app.sync_up()



def multithread_mode():

    total_count = 0

    thread_list = 

    for d in data_gen():

        print(d)

        total_count+=len(d)

        # app.batch_add(d)

        t=threading.Thread(target=app.batch_add,args=(d,))

        thread_list.append(t)

    for t in thread_list:

        t.start()



    for t in thread_list:

        t.join()



    print(total_count)





if __name__=='__main__':

    multithread_mode()

    data_validation()

File "/home/xda/miniconda3/envs/cpy/lib/python3.9/threading.py", line 910, in run

    self._target(*self._args, **self._kwargs)

  File "/home/xda/github/stock_strategy/sqlite_issue_debug.py", line 77, in batch_add

    self.db.commit()

Exception in thread Thread-3824:

Exception in thread Thread-3826:

Traceback (most recent call last):

  File "/home/xda/miniconda3/envs/cpy/lib/python3.9/threading.py", line 973, in _bootstrap_inner

sqlite3.OperationalError: cannot commit - no transaction is activeTraceback (most recent call last):

  File "/home/xda/github/stock_strategy/sqlite_issue_debug.py", line 72, in batch_add



    cursor.executemany(cmd, data)

sqlite3.InterfaceError: Error binding parameter 0 - probably unsupported type.

获取分笔数据 ContextInfo.get_full_tick()

package cache



import (

	"server/service"

	"fmt"

	"github.com/go-redis/redis"

)



type Cache struct {

	conn *redis.Client

}



func (this *Cache) CacheInit() {

	this.connect()



}

func (this *Cache) connect() {

	conf := service.ReadRedisConfig()

	this.conn = redis.NewClient(&redis.Options{

		Addr:     conf.Addr,

		Password: conf.Password,

		DB:       conf.DB,

	})



}

func (this *Cache) Get(id string) (string, bool) {

	result, err := this.conn.Get(id).Result()

	if err != nil {

		fmt.Println(err)

		return "", false

	}

	return result, true

}



func (this *Cache) Set(id string, content string) bool {

	_, err := this.conn.Set(id, content, 0).Result()

	if err != nil {

		fmt.Println(err)

		return false

	} else {

		return true

	}

}



func (this *Cache) CheckUserExist(sign string) bool {

	result, err := this.conn.SIsMember("User", sign).Result()

	if err != nil {

		fmt.Println(err)

		return false

	}

	return result

}



func (this *Cache) AddUser(name string) bool {

	_, err := this.conn.SAdd("User", name).Result()

	if err != nil {

		fmt.Println(err)

		return false

	} else {

		return true

	}



}

上交所发布关于可转换公司债券适当性管理相关事项的通知，个人投资者参与向不特定对象发行的可转债申购、交易，应当同时符合下列条件：申请权限开通前20个交易日证券账户及资金账户内的资产日均不低于人民币10万元（不包括该投资者通过融资融券融入的资金和证券）；参与证券交易24个月以上。

get_history(5, frequency='1d', field='close', security_list=['123084.SZ'], fq=None, include=False, fill='nan')

APScheduler (3.3.1)

arch (3.2)

bcolz (1.2.1)

beautifulsoup4 (4.6.0)

bleach (1.5.0)

boto (2.43.0)

Bottleneck (1.0.0)

bz2file (0.98)

cachetools (3.1.0)

click (4.0)

contextlib2 (0.4.0)

crypto (1.4.1)

cvxopt (1.1.8)

cx-Oracle (8.0.1)

cycler (0.10.0)

cyordereddict (0.2.2)

Cython (0.22.1)

decorator (4.0.10)

entrypoints (0.2.2)

fastcache (1.0.2)

gensim (0.13.3)

h5py (2.6.0)

hmmlearn (0.2.0)

hs-udata (0.3.6)

html5lib (0.9999999)

ipykernel (4.5.0)

ipython (5.1.0)

ipython-genutils (0.1.0)

ipywidgets (5.2.2)

jieba (0.38)

Jinja2 (2.8)

jsonpickle (1.0)

jsonschema (2.5.1)

jupyter (1.0.0)

jupyter-client (4.4.0)

jupyter-console (5.0.0)

jupyter-core (4.2.0)

jupyter-kernel-gateway (1.1.1)

Keras (2.3.1)

Keras-Applications (1.0.8)

Keras-Preprocessing (1.1.0)

line-profiler (2.1.2)

Logbook (1.4.3)

lxml (4.5.0)

Markdown (2.2.0)

MarkupSafe (0.23)

matplotlib (1.5.3)

mistune (0.7.3)

Naked (0.1.31)

nbconvert (4.2.0)

nbformat (4.1.0)

networkx (1.9.1)

nose (1.3.6)

notebook (4.2.3)

numexpr (2.6.1)

numpy (1.11.2)

pandas (0.23.4)

patsy (0.4.0)

pexpect (4.2.1)

pickleshare (0.7.4)

pip (9.0.1)

pkgconfig (1.0.0)

prompt-toolkit (1.0.8)

protobuf (3.3.0)

ptvsd (2.2.0)

ptyprocess (0.5.1)

PyBrain (0.3)

pycrypto (2.6.1)

Pygments (2.1.3)

PyMySQL (0.9.3)

pyparsing (2.1.10)

python-dateutil (2.7.5)

pytz (2015.4)

PyWavelets (0.4.0)

PyYAML (5.3.1)

pyzmq (16.1.0.dev0)

qtconsole (4.2.1)

requests (2.7.0)

retrying (1.3.3)

scikit-learn (0.18)

scipy (0.18.0)

seaborn (0.7.1)

setuptools (28.7.1)

setuptools-scm (3.1.0)

shellescape (3.4.1)

simplegeneric (0.8.1)

simplejson (3.17.0)

six (1.10.0)

sklearn (0.0)

smart-open (1.3.5)

SQLAlchemy (1.0.8)

statsmodels (0.10.2)

TA-Lib (0.4.10)

tables (3.3.0)

tabulate (0.7.5)

tensorflow (1.3.0rc1)

tensorflow-tensorboard (0.1.2)

terminado (0.6)

Theano (0.8.2)

toolz (0.7.4)

tornado (4.4.2)

traitlets (4.3.1)

tushare (1.2.48)

tzlocal (1.3)

wcwidth (0.1.7)

Werkzeug (0.12.2)

wheel (0.29.0)

widgetsnbextension (1.2.6)

xcsc-tushare (1.0.0)

xgboost (0.6a2)

xlrd (1.1.0)

xlwt (1.3.0)

zipline (0.8.3)

You are using pip version 9.0.1, however version 22.1.2 is available.

You should consider upgrading via the 'pip install --upgrade pip' command.

在中国网络环境下获取Golang.org上的Golang Packages

背景

目前在中国网络环境下无法访问Golang.org。

问题

不能运行go get golang.org/x/XX来获取Golang packages。

解决方案

方案 A: 使用github 上的镜像



获取Golang Package在github镜像上的路径: golang.org/x/PATH_TO_PACKAGE --> github.com/golang/PATH_TO_PACKAGE.



   // Ex:

   golang.org/x/net/context --> github.com/golang/net/context

运行go get来安装github镜像的Golang packages。



   // Ex:

   go get github.com/golang/net/context

你会碰到如下错误提示:



   package github.com/golang/net/context:

   code in directory /go/src/github.com/golang/net/context

   expects import "golang.org/x/net/context"

忽略错误。 Golang的Package的源代码已经成功下载于：

$GOPATH/src/github.com/golang/PATH_TO_PACKAGE.



复制 $GOPATH/src/github.com/golang/PATH_TO_PACKAGE 到 $GOPATH/src/golang.org/x/PATH_TO_PACKAGE.



   // Ex:

   mkdir $GOPATH/src/golang.org/x -p

   cp $GOPATH/src/github.com/golang/net $GOPATH/src/golang.org/x/ -rf

运行 go build 来编译。



方案 B: 使用第三方网站 - https://gopm.io/download



输入包路径即可下载zip文件。

conn = pymysql.connect(host=host, port=port, user=user, password=password, db=db, charset='utf8',timeout=3)
 

import requests



def initialize(context):

    # 初始化策略

    g.security = "600570.SS"

    set_universe(g.security)



    

def handle_data(context, data):

    

    url='http://www.baidu.com'

    headers={'User-Agent':'Google'}

    try:

        r=requests.get(url,headers=headers)

        r.encoding='utf8'

        print(r.text)

    except Exception as e:

        print('error')

        print(e)

The rshim driver provides a way to access the rshim resources on the BlueField target from external host machine

<script type="text/javascript">

    var submitBTN = document.getElementById("url_update");

    submitBTN.onclick = function (event) {

        // 注意这里是 onclick 函数

        console.log("click");

        $.ajax({

            url: "/update-site1",

            type: "POST",

            data: {value:1},

            cache: false,

            contentType: "application/x-www-form-urlencoded",

            success: function (data) {

                console.log(data);



                if (data.code !== 0) {

                    alert('更新失败')

                } else {

                    new_str = data.res + " " + data.count

                    $("#txt_content").val(new_str);

                    alert('更新资源成功！')

                }

            },

            fail: function (data) {

                alert("更新失败!");

            }

        });



        $.ajax({

            url: "/update-site1",

            type: "POST",

            data: {value:2},

            cache: false,

            contentType: "application/x-www-form-urlencoded",

            success: function (data) {

                console.log(data);



                if (data.code !== 0) {

                    alert('更新失败')

                } else {

                    new_str = data.res + " " + data.count

                    $("#txt_content").val(new_str);

                    alert('更新资源成功！')

                }

            },

            fail: function (data) {

                alert("更新失败!");

            }

        })



    }

    

</script>

contentType: "application/x-www-form-urlencoded",

processData: false,

	router.POST("/update-site1", controllers.BaiduSite1)

func BaiduSite1(ctx *gin.Context) {

	if ctx.Request.Method == "POST" {



		value := ctx.PostForm("value")

		fmt.Println(value)

		int_value, err := strconv.Atoi(value)

		if err != nil {

			ctx.JSON(http.StatusOK, gin.H{

				"code":  1,

				"res":   "",

				"count": 0,

			})

			return

		}

		res, count := webmaster.PushProcess(1, int_value)

		ctx.JSON(http.StatusOK, gin.H{

			"code":  0,

			"res":   res,

			"count": count,

		})

	}

}

value := ctx.PostForm("value")

ctx.JSON(http.StatusOK, gin.H{

			"code":  0,

			"res":   res,

			"count": count,