April 2019 – Records And Memorys

hausdorff 距离

定义：

Hausdorff distance assigns to each point of one set the distance to its closest point on the other and takes the maximum over all these values.

1
2
3

Hausdorff distance
assigns to each point of one set the distance to its closest point on the other and takes
the maximum over all these values.

对一条线的每一个点，计算另一条线上距离它最近的点，计为d1 , 对于 d1,d2,d3…..dN 的点集，取其中的最大值，即为hausdorff 距离

用途：

given an object A find the most
simple object A0 resembling A within given tolerance;

1 2	given an object A find the most simple object A0 resembling A within given tolerance;

给定一个形状 A ,找出 A在指定容忍范围内的最相似形状 A0

公式：

Let A , B ⊂ R² --- compact, we define the one-sided Hausdorff distance from A to B as δₕ（A，B） = max (~δₕ(A,B),~δₕ(B,A))

1
2
3
4
5

Let A , B ⊂ R² --- compact, we define the one-sided Hausdorff distance
from A to B as

δₕ（A，B） = max (~δₕ(A,B),~δₕ(B,A))

双向 Hausdorff 距离

算法

如果想比较两个曲线有多相像，必须先有模型量化什么是相像，也就是：怎么定义 similar

参考文章

https://www.cnblogs.com/luxiaoxun/archive/2013/05/09/3069036.html#undefined

Dynamic Time Warping 动态时间规整算法

到现在为止的实现方法(2019-05-16)

import sys
# import matplotlib.pylab as plt
import matplotlib.pyplot as plt
import matplotlib.animation as animation
import matplotlib.dates as md
import pymysql
import numpy as np
import datetime as dt
import pandas as pd
import seaborn as sns
import time

import sys
#sys.argv += 'if1906_20190516 09:30:00 10:00:00'.split()

def normalizeArray(pa):
    amin,amax = min(pa),max(pa)
    for j in range(len(pa)):
        pa[j]=(pa[j]-amin)/(amax-amin)


def distance_cost_plot(distances):
    im = plt.imshow(distances, interpolation='nearest', cmap='Reds') 
    plt.gca().invert_yaxis()
    plt.xlabel("X")
    plt.ylabel("Y")
    plt.grid()
    plt.colorbar()
    #plt.show()


def path_cost(x, y, accumulated_cost, distances):
    path = [[len(x)-1, len(y)-1]]
    cost = 0
    i = len(y)-1
    j = len(x)-1
    while i>0 and j>0:
        if i==0:
            j = j - 1
        elif j==0:
            i = i - 1
        else:
            if accumulated_cost[i-1, j] == min(accumulated_cost[i-1, j-1], accumulated_cost[i-1, j], accumulated_cost[i, j-1]):
                i = i - 1
            elif accumulated_cost[i, j-1] == min(accumulated_cost[i-1, j-1], accumulated_cost[i-1, j], accumulated_cost[i, j-1]):
                j = j-1
            else:
                i = i - 1
                j= j- 1
        path.append([j, i])
    path.append([0,0])
    for [y, x] in path:
        cost = cost +distances[x, y]
    return path, cost   



conn=pymysql.connect(host='localhost',user='root',password='MYSQLTB',db='shfuture')
a=conn.cursor()

sql = 'select lastprice ,case when hour(happentime)<=11 then DATE_ADD(happentime,interval 90 minute) else happentime end  from ' + sys.argv[1]  + ' where time(happentime)>"'  + sys.argv[2]  + '" and time(happentime)<"' + sys.argv[3]  + '";' 
print(sql)
a.execute(sql)
data=a.fetchall()


x=[]
s0=[]
for result in data:
    x.append(result[0])
    s0.append(result[1])

#print(x)
normalizeArray(x)
print('orignal array have ' , len(x) , ' elements ')

print('************************************************')


loopi = 1 
loopTableName = sys.argv[1]
while loopi < 20:
    loopi = loopi + 1
    #sql = 'select lastprice ,case when hour(happentime)<=11 then DATE_ADD(happentime,interval 90 minute) else happentime end  from if1906_20190419'   + ' where time(happentime)<"'  + sys.argv[2]  + '";'
    sql = 'SELECT table_name FROM INFORMATION_SCHEMA.TABLES WHERE table_schema = "shfuture" and table_name like "if%" and table_name < "' + loopTableName + '" order by create_time desc limit 1;'

    #print(sql)
    a.execute(sql)
    data=a.fetchall()
    for result in data:
        loopTableName = result[0]
    print(loopTableName)

    sql = 'select lastprice ,case when hour(happentime)<=11 then DATE_ADD(happentime,interval 90 minute) else happentime end  from ' + loopTableName  + ' where time(happentime)>"'  + sys.argv[2]  + '" and time(happentime)<"' + sys.argv[3]  + '";' 
    #print(sql)
    a.execute(sql)
    data=a.fetchall()

    y=[]
    s0=[]
    for result in data:
        y.append(result[0])
        s0.append(result[1])
    #print(y)

    #s = time.time()
    normalizeArray(y)
    #print("original array normalize  Took %f seconds" % (time.time() - s))

    distances = np.zeros((len(y), len(x)))    #建立一个 len(y) 行 , len(x) 列 的矩阵 ，并初始化为零
    #print(distances)

    s = time.time()
    for i in range(len(y)):
        for j in range(len(x)):
            distances[i,j] = (x[j]-y[i])**2    # 计算 y的每个点到 x的距离 

    print("cal x y distance matrix use time %f seconds" % (time.time() - s))

    #print(distances)        

    #distance_cost_plot(distances)

    # 另一个矩阵
    accumulated_cost = np.zeros((len(y), len(x)))
    accumulated_cost[0,0] = distances[0,0]

    s = time.time()
    for i in range(1, len(x)):
        accumulated_cost[0,i] = distances[0,i] + accumulated_cost[0, i-1]    

    for i in range(1, len(y)):
        accumulated_cost[i,0] = distances[i, 0] + accumulated_cost[i-1, 0]    

    for i in range(1, len(y)):
        for j in range(1, len(x)):
            accumulated_cost[i, j] = min(accumulated_cost[i-1, j-1], accumulated_cost[i-1, j], accumulated_cost[i, j-1]) + distances[i, j]    #这句是最慢的 
    
    print("cal accumulate matrix use time %f seconds" % (time.time() - s))

    #distance_cost_plot(accumulated_cost)    不用画图

    #找出最短路径 
    s = time.time()
    path, cost = path_cost(x, y, accumulated_cost, distances)
    print("find shortest path use time %f seconds" % (time.time() - s))
    #print(path)
    print('DTM value from ' , sys.argv[1]  , ' to ' , loopTableName  , ' is '  , cost)

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

import sys

# import matplotlib.pylab as plt

import matplotlib.pyplot as plt

import matplotlib.animation as animation

import matplotlib.dates as md

import pymysql

import numpy as np

import datetime as dt

import pandas as pd

import seaborn as sns

import time

import sys

#sys.argv += 'if1906_20190516 09:30:00 10:00:00'.split()

def normalizeArray(pa):

amin,amax = min(pa),max(pa)

for j in range(len(pa)):

pa[j]=(pa[j]-amin)/(amax-amin)

def distance_cost_plot(distances):

im = plt.imshow(distances, interpolation='nearest', cmap='Reds')

plt.gca().invert_yaxis()

plt.xlabel("X")

plt.ylabel("Y")

plt.grid()

plt.colorbar()

#plt.show()

def path_cost(x, y, accumulated_cost, distances):

path = [[len(x)-1, len(y)-1]]

cost = 0

i = len(y)-1

j = len(x)-1

while i>0 and j>0:

if i==0:

j = j - 1

elif j==0:

i = i - 1

else:

if accumulated_cost[i-1, j] == min(accumulated_cost[i-1, j-1], accumulated_cost[i-1, j], accumulated_cost[i, j-1]):

i = i - 1

elif accumulated_cost[i, j-1] == min(accumulated_cost[i-1, j-1], accumulated_cost[i-1, j], accumulated_cost[i, j-1]):

j = j-1

else:

i = i - 1

j= j- 1

path.append([j, i])

path.append([0,0])

for [y, x] in path:

cost = cost +distances[x, y]

return path, cost

conn=pymysql.connect(host='localhost',user='root',password='MYSQLTB',db='shfuture')

a=conn.cursor()

sql = 'select lastprice ,case when hour(happentime)<=11 then DATE_ADD(happentime,interval 90 minute) else happentime end from ' + sys.argv[1] + ' where time(happentime)>"' + sys.argv[2] + '" and time(happentime)<"' + sys.argv[3] + '";'

print(sql)

a.execute(sql)

data=a.fetchall()

x=[]

s0=[]

for result in data:

x.append(result[0])

s0.append(result[1])

#print(x)

normalizeArray(x)

print('orignal array have ' , len(x) , ' elements ')

print('************************************************')

loopi = 1

loopTableName = sys.argv[1]

while loopi < 20:

loopi = loopi + 1

#sql = 'select lastprice ,case when hour(happentime)<=11 then DATE_ADD(happentime,interval 90 minute) else happentime end from if1906_20190419' + ' where time(happentime)<"' + sys.argv[2] + '";'

sql = 'SELECT table_name FROM INFORMATION_SCHEMA.TABLES WHERE table_schema = "shfuture" and table_name like "if%" and table_name < "' + loopTableName + '" order by create_time desc limit 1;'

#print(sql)

a.execute(sql)

data=a.fetchall()

for result in data:

loopTableName = result[0]

print(loopTableName)

sql = 'select lastprice ,case when hour(happentime)<=11 then DATE_ADD(happentime,interval 90 minute) else happentime end from ' + loopTableName + ' where time(happentime)>"' + sys.argv[2] + '" and time(happentime)<"' + sys.argv[3] + '";'

#print(sql)

a.execute(sql)

data=a.fetchall()

y=[]

s0=[]

for result in data:

y.append(result[0])

s0.append(result[1])

#print(y)

#s = time.time()

normalizeArray(y)

#print("original array normalize Took %f seconds" % (time.time() - s))

distances = np.zeros((len(y), len(x))) #建立一个 len(y) 行 , len(x) 列的矩阵，并初始化为零

#print(distances)

s = time.time()

for i in range(len(y)):

for j in range(len(x)):

distances[i,j] = (x[j]-y[i])**2 # 计算 y的每个点到 x的距离

print("cal x y distance matrix use time %f seconds" % (time.time() - s))

#print(distances)

#distance_cost_plot(distances)

# 另一个矩阵

accumulated_cost = np.zeros((len(y), len(x)))

accumulated_cost[0,0] = distances[0,0]

s = time.time()

for i in range(1, len(x)):

accumulated_cost[0,i] = distances[0,i] + accumulated_cost[0, i-1]

for i in range(1, len(y)):

accumulated_cost[i,0] = distances[i, 0] + accumulated_cost[i-1, 0]

for i in range(1, len(y)):

for j in range(1, len(x)):

accumulated_cost[i, j] = min(accumulated_cost[i-1, j-1], accumulated_cost[i-1, j], accumulated_cost[i, j-1]) + distances[i, j] #这句是最慢的

print("cal accumulate matrix use time %f seconds" % (time.time() - s))

#distance_cost_plot(accumulated_cost) 不用画图

#找出最短路径

s = time.time()

path, cost = path_cost(x, y, accumulated_cost, distances)

print("find shortest path use time %f seconds" % (time.time() - s))

#print(path)

print('DTM value from ' , sys.argv[1] , ' to ' , loopTableName , ' is ' , cost)

缺点是速度太慢

怎么提升速度？

a) 合并数据，一分钟有 120个，用1个来替代

有人做的python 库

https://jekel.me/2017/Comparing-measures-of-similarity-between-curves/

拿两条正弦波图形测试

April 22, 2019

Net.core 当配置改变时触发回调函数

nuget 多安装 Microsoft.Extensions.DependencyInjection
Microsoft.Extensions.Options

https://ballardsoftware.com/adding-appsettings-json-configuration-to-a-net-core-console-application/ 怎么绑定 json config 文件，但不能实时更新

http://www.10tiao.com/html/391/201901/2654073587/4.html

https://stackoverflow.com/questions/38515965/cannot-set-configuration-from-json-appsettings-file-in-net-core-project

https://offering.solutions/blog/articles/2017/02/17/automatically-reload-typed-configuration-in-asp-net-core/ asp 的做法，但不是 c# console-application/

https://stackoverflow.com/questions/51969527/ioptionssnapshot-in-net-core-console-application-not-working 已经很接近的问题

当config值改变时，能通知应用程序
https://stackoverflow.com/questions/53604397/how-can-i-build-an-ioptionsmonitort-for-testing

例子： https://github.com/aspnet/Logging/issues/874

代码

using System;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Configuration.Binder;
using Microsoft.Extensions.Configuration.Json;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;

using System.Threading;
using Newtonsoft.Json;
namespace ConsoleApp1
{
    class Program
    {
        //static void ConfigureServices(IServiceCollection serviceCollection)
        //{

        //    // build configuration
        //    var configuration = new ConfigurationBuilder()
        //   .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)
        //   .Build();

        //    serviceCollection.AddSingleton()
        //    serviceCollection.Configure<AppSettings>(configuration.GetSection("Configuration"));

        //    // add services 
        //    serviceCollection.AddTransient<ITestService, TestService>();

        //    // add app
        //    serviceCollection.AddTransient<App>();
        //}
        //private static IServiceProvider provider;
        //private static EventReceiver receiver;


        static void Main(string[] args)
        {

            var config = new ConfigurationBuilder()
            .AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)
            .Build();

            var services = new ServiceCollection();

            //services.AddLogging(b =>
            //{
            //    b.AddConfiguration(config);
            //    b.AddConsole();
            //});

            services.AddOptions();
            services.Configure<MySettings>(config.GetSection("MySettings"));


            using (var sp = services.BuildServiceProvider())
            {
                var options = sp.GetRequiredService<IOptionsMonitor<MySettings>>();
                options.OnChange((o, name) => Console.WriteLine($"Name = {name}, Hash = {o.GetHashCode()}, Content = {JsonConvert.SerializeObject(o)}"));
            }

            Console.ReadLine();

            /*
            string sURL;


            var build = new ConfigurationBuilder()
           .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true);


            // IConfiguration config = new ConfigurationBuilder()
            //.AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)
            //.Build();


            IConfigurationRoot configuration = build.Build();



            IServiceProvider provider = new ServiceCollection()
                .Configure<MySettings>(
                    configuration.GetSection("MySettings"))
                .AddTransient<CheckOption>()
                .BuildServiceProvider();



            //var services = new ServiceCollection();
            //services.AddOptions();

            //services.Configure<MySettings>(configuration.GetSection("MySettings"));

            //var sp = services.BuildServiceProvider();

            //sURL = configuration["LocalServer"];


            while (true)
            {
                Thread.Sleep(1000);
                //configuration.Reload();
                //sURL = configuration["LocalServer"];

                CheckOption checkOption =
                    provider.GetRequiredService<CheckOption>();
                //checkOption.Run();


                //IOptionsSnapshot<MySettings> settings = sp.GetRequiredService<IOptionsSnapshot<MySettings>>();
                //var options = sp.GetService<IOptionsSnapshot<MySettings>>();
                //Console.WriteLine(options.Value.CurrentServer);

                //Console.WriteLine(settings.Value.CurrentServer);

                Console.WriteLine(checkOption.Run());
                //Console.WriteLine(sERRNAP);
            }




            //// create service collection
            //var serviceCollection = new ServiceCollection();
            //ConfigureServices(serviceCollection);

            //// create service provider
            //var serviceProvider = serviceCollection.BuildServiceProvider();

            //// entry to run app
            //serviceProvider.GetService<App>().Run();

             *////

        }

        private static void ConfigureServices(IServiceCollection services)
        {


        }

    }



    public class CheckOption
    {
        public MySettings _AppSettings;

        public CheckOption(IOptionsSnapshot<MySettings> appSettings)
        {
            _AppSettings = appSettings.Value;
        }

        public string Run()
        {
            string option1 = _AppSettings.CurrentServer;
            //string option2 = _AppSettings.Option2;
            return option1;
        }
    }




    //public class CheckOption
    //{
    //    public AppSettings _AppSettings;

    //    public CheckOption(IOptionsSnapshot<AppSettings> appSettings)
    //    {
    //        _AppSettings = appSettings.Value;
    //    }

    //    public void Run()
    //    {
    //        string option1 = _AppSettings.Option1;
    //        string option2 = _AppSettings.Option2;
    //    }
    //}

    public class MySettings
    {
        public string CurrentServer { get; set; }
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

using System;

using Microsoft.Extensions.Configuration;

using Microsoft.Extensions.Configuration.Binder;

using Microsoft.Extensions.Configuration.Json;

using Microsoft.Extensions.DependencyInjection;

using Microsoft.Extensions.Options;

using System.Threading;

using Newtonsoft.Json;

namespace ConsoleApp1

{

class Program

{

//static void ConfigureServices(IServiceCollection serviceCollection)

//{

// // build configuration

// var configuration = new ConfigurationBuilder()

// .AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)

// .Build();

// serviceCollection.AddSingleton()

// serviceCollection.Configure<AppSettings>(configuration.GetSection("Configuration"));

// // add services

// serviceCollection.AddTransient<ITestService, TestService>();

// // add app

// serviceCollection.AddTransient<App>();

//}

//private static IServiceProvider provider;

//private static EventReceiver receiver;

static void Main(string[] args)

{

var config = new ConfigurationBuilder()

.AddJsonFile("appsettings.json", optional: false, reloadOnChange: true)

.Build();

var services = new ServiceCollection();

//services.AddLogging(b =>

//{

// b.AddConfiguration(config);

// b.AddConsole();

//});

services.AddOptions();

services.Configure<MySettings>(config.GetSection("MySettings"));

using (var sp = services.BuildServiceProvider())

{

var options = sp.GetRequiredService<IOptionsMonitor<MySettings>>();

options.OnChange((o, name) => Console.WriteLine($"Name = {name}, Hash = {o.GetHashCode()}, Content = {JsonConvert.SerializeObject(o)}"));

}

Console.ReadLine();

string sURL;

var build = new ConfigurationBuilder()

.AddJsonFile("appsettings.json", optional: true, reloadOnChange: true);

// IConfiguration config = new ConfigurationBuilder()

//.AddJsonFile("appsettings.json", optional: true, reloadOnChange: true)

//.Build();

IConfigurationRoot configuration = build.Build();

IServiceProvider provider = new ServiceCollection()

.Configure<MySettings>(

configuration.GetSection("MySettings"))

.AddTransient<CheckOption>()

.BuildServiceProvider();

//var services = new ServiceCollection();

//services.AddOptions();

//services.Configure<MySettings>(configuration.GetSection("MySettings"));

//var sp = services.BuildServiceProvider();

//sURL = configuration["LocalServer"];

while (true)

{

Thread.Sleep(1000);

//configuration.Reload();

//sURL = configuration["LocalServer"];

CheckOption checkOption =

provider.GetRequiredService<CheckOption>();

//checkOption.Run();

//IOptionsSnapshot<MySettings> settings = sp.GetRequiredService<IOptionsSnapshot<MySettings>>();

//var options = sp.GetService<IOptionsSnapshot<MySettings>>();

//Console.WriteLine(options.Value.CurrentServer);

//Console.WriteLine(settings.Value.CurrentServer);

Console.WriteLine(checkOption.Run());

//Console.WriteLine(sERRNAP);

}

//// create service collection

//var serviceCollection = new ServiceCollection();

//ConfigureServices(serviceCollection);

//// create service provider

//var serviceProvider = serviceCollection.BuildServiceProvider();

//// entry to run app

//serviceProvider.GetService<App>().Run();

*////

}

private static void ConfigureServices(IServiceCollection services)

{

}

public class CheckOption

{

public MySettings _AppSettings;

public CheckOption(IOptionsSnapshot<MySettings> appSettings)

{

_AppSettings = appSettings.Value;

}

public string Run()

{

string option1 = _AppSettings.CurrentServer;

//string option2 = _AppSettings.Option2;

return option1;

}

//public class CheckOption

//{

// public AppSettings _AppSettings;

// public CheckOption(IOptionsSnapshot<AppSettings> appSettings)

// {

// _AppSettings = appSettings.Value;

// }

// public void Run()

// {

// string option1 = _AppSettings.Option1;

// string option2 = _AppSettings.Option2;

// }

//}

public class MySettings

{

public string CurrentServer { get; set; }

}

配套配置文件：

{
"MySettings": {
 "CurrentServer": "XBACTaaabbbccXXX"
},
 "LocalServer": "XBACTwwwaaa"
}

{

"MySettings": {

"CurrentServer": "XBACTaaabbbccXXX"

"LocalServer": "XBACTwwwaaa"

}

April 19, 2019April 19, 2019

TB 的 timer 是怎么实现的

Timer 是一个类，包含在其他类里面(callleg) , 另有线程(CMCLib)负责所有的timer 实例，并把timerout event 发送回timer 所在的类

CTBCMCLib::GetInstance()->SendEvent( un32LegId, pEvent );

1	CTBCMCLib::GetInstance()->SendEvent( un32LegId, pEvent );

用 LegId标识 leg的实体， in file CTBCMCLib.cpp , 但是 tbcmc_lib.c 并没有源码

April 11, 2019

c# get cpu use percent and available memory

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Diagnostics;
using System.Threading;

namespace CPUAndMemory
{
    class Program
    {

        static void Main(string[] args)
        {

            PerformanceCounter ram = new PerformanceCounter("Memory", "Available MBytes", null);
            //PerformanceCounter ram = new  PerformanceCounter("Memory", "Committed Bytes", null);

            //PerformanceCounter pageCounter = new PerformanceCounter
            //("Paging File", "% Usage", "_Total", "DESKTOP-EL8EIRQ");



             PerformanceCounter theCPUCounter = new PerformanceCounter("Processor", "% Processor Time", "_Total");




             while (true)
             {
                 Thread.Sleep(1000);
                 Console.WriteLine(theCPUCounter.NextValue() + "%");
                 Console.WriteLine("RAM: " + ram.NextValue() + " MB");
             }

             Console.ReadLine();

        }
    }
}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.Diagnostics;

using System.Threading;

namespace CPUAndMemory

{

class Program

{

static void Main(string[] args)

{

PerformanceCounter ram = new PerformanceCounter("Memory", "Available MBytes", null);

//PerformanceCounter ram = new PerformanceCounter("Memory", "Committed Bytes", null);

//PerformanceCounter pageCounter = new PerformanceCounter

//("Paging File", "% Usage", "_Total", "DESKTOP-EL8EIRQ");

PerformanceCounter theCPUCounter = new PerformanceCounter("Processor", "% Processor Time", "_Total");

while (true)

{

Thread.Sleep(1000);

Console.WriteLine(theCPUCounter.NextValue() + "%");

Console.WriteLine("RAM: " + ram.NextValue() + " MB");

}

Console.ReadLine();

}

其他可取的选项：

 PerformanceCounter("Processor", "% Processor Time", "_Total");
 PerformanceCounter("Processor", "% Privileged Time", "_Total");
 PerformanceCounter("Processor", "% Interrupt Time", "_Total");
 PerformanceCounter("Processor", "% DPC Time", "_Total");
 PerformanceCounter("Memory", "Available MBytes", null);
 PerformanceCounter("Memory", "Committed Bytes", null);
 PerformanceCounter("Memory", "Commit Limit", null);
 PerformanceCounter("Memory", "% Committed Bytes In Use", null);
 PerformanceCounter("Memory", "Pool Paged Bytes", null);
 PerformanceCounter("Memory", "Pool Nonpaged Bytes", null);
 PerformanceCounter("Memory", "Cache Bytes", null);
 PerformanceCounter("Paging File", "% Usage", "_Total");
 PerformanceCounter("PhysicalDisk", "Avg. Disk Queue Length", "_Total");
 PerformanceCounter("PhysicalDisk", "Disk Read Bytes/sec", "_Total");
 PerformanceCounter("PhysicalDisk", "Disk Write Bytes/sec", "_Total");
 PerformanceCounter("PhysicalDisk", "Avg. Disk sec/Read", "_Total");
 PerformanceCounter("PhysicalDisk", "Avg. Disk sec/Write", "_Total");
 PerformanceCounter("PhysicalDisk", "% Disk Time", "_Total");
 PerformanceCounter("Process", "Handle Count", "_Total");
 PerformanceCounter("Process", "Thread Count", "_Total");
 PerformanceCounter("System", "Context Switches/sec", null);
 PerformanceCounter("System", "System Calls/sec", null);
 PerformanceCounter("System", "Processor Queue Length", null);

PerformanceCounter("Processor", "% Processor Time", "_Total");

PerformanceCounter("Processor", "% Privileged Time", "_Total");

PerformanceCounter("Processor", "% Interrupt Time", "_Total");

PerformanceCounter("Processor", "% DPC Time", "_Total");

PerformanceCounter("Memory", "Available MBytes", null);

PerformanceCounter("Memory", "Committed Bytes", null);

PerformanceCounter("Memory", "Commit Limit", null);

PerformanceCounter("Memory", "% Committed Bytes In Use", null);

PerformanceCounter("Memory", "Pool Paged Bytes", null);

PerformanceCounter("Memory", "Pool Nonpaged Bytes", null);

PerformanceCounter("Memory", "Cache Bytes", null);

PerformanceCounter("Paging File", "% Usage", "_Total");

PerformanceCounter("PhysicalDisk", "Avg. Disk Queue Length", "_Total");

PerformanceCounter("PhysicalDisk", "Disk Read Bytes/sec", "_Total");

PerformanceCounter("PhysicalDisk", "Disk Write Bytes/sec", "_Total");

PerformanceCounter("PhysicalDisk", "Avg. Disk sec/Read", "_Total");

PerformanceCounter("PhysicalDisk", "Avg. Disk sec/Write", "_Total");

PerformanceCounter("PhysicalDisk", "% Disk Time", "_Total");

PerformanceCounter("Process", "Handle Count", "_Total");

PerformanceCounter("Process", "Thread Count", "_Total");

PerformanceCounter("System", "Context Switches/sec", null);

PerformanceCounter("System", "System Calls/sec", null);

PerformanceCounter("System", "Processor Queue Length", null);

April 8, 2019

how to reset wordpress login pwd

loging mysql

find current user :

SELECT ID, user_login, user_pass FROM wp_users;

1	SELECT ID, user_login, user_pass FROM wp_users;

update user password

UPDATE wp_users SET user_pass=MD5('newstrongpassword') WHERE ID = usersID;

1	UPDATE wp_users SET user_pass=MD5('newstrongpassword') WHERE ID = usersID;

April 4, 2019April 4, 2019

python scripts

画实时k线

import sys
import matplotlib.pyplot as plt
import matplotlib.animation as animation
import pymysql
from scipy import stats
import numpy as np
import datetime
import time

x = datetime.datetime(2019,4,4,9,30)
firstTop =0
doubletop=0
FuPanIndexBegin = 0

sellingPrice = 0

lowPrice = 0
lastStopWinPrice = 0 

oporTime = 0
CurrentState = 0      #  0 mean observer ,  1 selling , 2 buying  

Todaymin=0
Todaymax =0

conn=pymysql.connect(host='localhost',user='root',password='MYSQLTB',db='shfuture')
a=conn.cursor()

t=[]
s=[]

dat=[0,1]
plt.plot(dat)
plt.ion()
plt.show()  

while True: 
    sql = 'select happentime,lastprice from ' + sys.argv[1]  + ' where happentime<=%s and hour(happentime)>=9  order by happentime desc limit 2;'
    a.execute(sql,x)
    data=a.fetchall()
    for result in data:
        t.append(result[0])
        s.append(result[1])

    x= x + datetime.timedelta(seconds=1)
    
    plt.plot(t, s)
    plt.draw()
    plt.pause(0.0001)
    plt.clf()

import sys

import matplotlib.pyplot as plt

import matplotlib.animation as animation

import pymysql

from scipy import stats

import numpy as np

import datetime

import time

x = datetime.datetime(2019,4,4,9,30)

firstTop =0

doubletop=0

FuPanIndexBegin = 0

sellingPrice = 0

lowPrice = 0

lastStopWinPrice = 0

oporTime = 0

CurrentState = 0 # 0 mean observer , 1 selling , 2 buying

Todaymin=0

Todaymax =0

conn=pymysql.connect(host='localhost',user='root',password='MYSQLTB',db='shfuture')

a=conn.cursor()

t=[]

s=[]

dat=[0,1]

plt.plot(dat)

plt.ion()

plt.show()

while True:

sql = 'select happentime,lastprice from ' + sys.argv[1] + ' where happentime<=%s and hour(happentime)>=9 order by happentime desc limit 2;'

a.execute(sql,x)

data=a.fetchall()

for result in data:

t.append(result[0])

s.append(result[1])

x= x + datetime.timedelta(seconds=1)

plt.plot(t, s)

plt.draw()

plt.pause(0.0001)

plt.clf()

参考 https://stackoverflow.com/questions/4098131/how-to-update-a-plot-in-matplotlib

最后一个答案