datasets

package
v0.5.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 23, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BaseXdxr             = cache.PluginMaskBaseData | (baseKind + 1) // 基础数据-除权除息
	BaseKLine            = cache.PluginMaskBaseData | (baseKind + 2) // 基础数据-基础K线
	BaseTransaction      = cache.PluginMaskBaseData | (baseKind + 3) // 基础数据-历史成交
	BaseMinutes          = cache.PluginMaskBaseData | (baseKind + 4) // 基础数据-分时数据
	BaseQuarterlyReports = cache.PluginMaskBaseData | (baseKind + 5) // 基础数据-季报
	BaseSafetyScore      = cache.PluginMaskBaseData | (baseKind + 6) // 基础数据-安全分

)

Variables

This section is empty.

Functions

func BasicKLine added in v0.1.5 

func BasicKLine(securityCode string) pandas.DataFrame

BasicKLine 基础日K线

func CountInflow added in v0.2.0 

func CountInflow(list []quotes.TickTransaction, securityCode string, date string) (summary cache.TurnoverDataSummary)

CountInflow 统计指定日期的内外盘

func GetDataDescript added in v0.2.0 

func GetDataDescript(kind cache.Kind) cache.DataSummary

func IntegrateQuarterlyReports added in v0.1.5 

func IntegrateQuarterlyReports(barIndex int, date string) map[string]dfcf.QuarterlyReport

IntegrateQuarterlyReports 更新季报数据

func KLineToWeekly added in v0.1.5 

func KLineToWeekly(kline pandas.DataFrame) pandas.DataFrame

KLineToWeekly 日线转周线 

deprecated: 不推荐使用

func MonthlyKLine added in v0.1.5 

func MonthlyKLine(securityCode string, cacheKLine ...[]base.KLine) (df pandas.DataFrame)

MonthlyKLine 月K线

func WeeklyKLine added in v0.1.5 

func WeeklyKLine(securityCode string, cacheKLine ...[]base.KLine) (df pandas.DataFrame)

WeeklyKLine 周线

Types

type DataKLine 

type DataKLine struct {
	cache.DataSummary
	Date string
	Code string
}

func (*DataKLine) Check added in v0.2.3 

func (k *DataKLine) Check(cacheDate, featureDate string) error

func (*DataKLine) Checkout added in v0.3.2 

func (k *DataKLine) Checkout(securityCode, date string)

func (*DataKLine) Clone 

func (k *DataKLine) Clone(date, code string) DataSet

func (*DataKLine) Filename 

func (k *DataKLine) Filename(date, code string) string

func (*DataKLine) GetDate added in v0.3.4 

func (k *DataKLine) GetDate() string

func (*DataKLine) GetSecurityCode added in v0.3.4 

func (k *DataKLine) GetSecurityCode() string

func (*DataKLine) Increase 

func (k *DataKLine) Increase(snapshot quotes.Snapshot)

func (*DataKLine) Init added in v0.1.5 

func (k *DataKLine) Init(ctx context.Context, date string) error

func (*DataKLine) Print added in v0.2.0 

func (k *DataKLine) Print(code string, date ...string)

func (*DataKLine) Repair 

func (k *DataKLine) Repair(date string)

func (*DataKLine) Update 

func (k *DataKLine) Update(date string)

type DataQuarterlyReport added in v0.1.5 

type DataQuarterlyReport struct {
	cache.DataSummary
	Date string
	Code string
	// contains filtered or unexported fields
}

DataQuarterlyReport 季报

func (*DataQuarterlyReport) Check added in v0.2.3 

func (r *DataQuarterlyReport) Check(cacheDate, featureDate string) error

func (*DataQuarterlyReport) Checkout added in v0.3.2 

func (r *DataQuarterlyReport) Checkout(securityCode, date string)

func (*DataQuarterlyReport) Clone added in v0.1.5 

func (r *DataQuarterlyReport) Clone(date string, code string) DataSet

func (*DataQuarterlyReport) Filename added in v0.1.5 

func (r *DataQuarterlyReport) Filename(date, code string) string

func (*DataQuarterlyReport) GetDate added in v0.3.4 

func (r *DataQuarterlyReport) GetDate() string

func (*DataQuarterlyReport) GetSecurityCode added in v0.3.4 

func (r *DataQuarterlyReport) GetSecurityCode() string

func (*DataQuarterlyReport) Increase added in v0.1.5 

func (r *DataQuarterlyReport) Increase(snapshot quotes.Snapshot)

func (*DataQuarterlyReport) Init added in v0.1.5 

func (r *DataQuarterlyReport) Init(ctx context.Context, date string) error

func (*DataQuarterlyReport) Print added in v0.2.0 

func (r *DataQuarterlyReport) Print(code string, date ...string)

func (*DataQuarterlyReport) Repair added in v0.1.5 

func (r *DataQuarterlyReport) Repair(date string)

func (*DataQuarterlyReport) Update added in v0.1.5 

func (r *DataQuarterlyReport) Update(date string)

type DataSafetyScore deprecated added in v0.1.5 

type DataSafetyScore struct {
	cache.DataSummary
}

DataSafetyScore 个股基本面安全评分 

Deprecated: 废弃

type DataSet 

type DataSet interface {
	cache.Manifest
	// Update 更新数据
	Update(date string)
	// Repair 回补数据
	Repair(date string)
	// Increase 增量计算, 用快照增量计算特征
	Increase(snapshot quotes.Snapshot)
	// Clone 克隆一个DataSet
	Clone(date string, code string) DataSet
}

DataSet 数据层, 数据集接口 smart 

数据集是基础数据, 应当遵循结构简单, 尽量减小缓存的文件数量, 加载迅速
检索的规则是按日期和代码进行查询

type DataXdxr 

type DataXdxr struct {
	cache.DataSummary
	Date string
	Code string
}

DataXdxr 除权除息

func (*DataXdxr) Clone 

func (x *DataXdxr) Clone(date string, code string) DataSet

func (*DataXdxr) Filename 

func (x *DataXdxr) Filename(date, code string) string

func (*DataXdxr) GetDate added in v0.3.4 

func (x *DataXdxr) GetDate() string

func (*DataXdxr) GetSecurityCode added in v0.3.4 

func (x *DataXdxr) GetSecurityCode() string

func (*DataXdxr) Increase 

func (x *DataXdxr) Increase(snapshot quotes.Snapshot)

func (*DataXdxr) Init added in v0.1.5 

func (x *DataXdxr) Init(ctx context.Context, date string) error

func (*DataXdxr) Print added in v0.2.0 

func (x *DataXdxr) Print(code string, date ...string)

func (*DataXdxr) Repair 

func (x *DataXdxr) Repair(date string)

func (*DataXdxr) Update 

func (x *DataXdxr) Update(date string)

type MovingAverage added in v0.1.5 

type MovingAverage struct {
	MA5  float64 // 5日均线
	MA10 float64 // 10日均线
	MA20 float64 // 20日均线
}

MovingAverage 移动平均线(MA)

type TransactionRecord added in v0.2.0 

type TransactionRecord struct {
	cache.DataSummary
	Date string
	Code string
}

TransactionRecord 成交记录 

最短3秒内的合并统计数据, 与行情数据保持一致
不可以当作tick数据来使用

func (*TransactionRecord) Check added in v0.2.3 

func (r *TransactionRecord) Check(cacheDate, featureDate string) error

func (*TransactionRecord) Checkout added in v0.3.2 

func (r *TransactionRecord) Checkout(securityCode, date string)

func (*TransactionRecord) Clone added in v0.2.0 

func (r *TransactionRecord) Clone(date string, code string) DataSet

func (*TransactionRecord) Filename added in v0.2.0 

func (r *TransactionRecord) Filename(date, code string) string

func (*TransactionRecord) GetDate added in v0.3.4 

func (r *TransactionRecord) GetDate() string

func (*TransactionRecord) GetSecurityCode added in v0.3.4 

func (r *TransactionRecord) GetSecurityCode() string

func (*TransactionRecord) Increase added in v0.2.0 

func (r *TransactionRecord) Increase(snapshot quotes.Snapshot)

func (*TransactionRecord) Init added in v0.2.0 

func (r *TransactionRecord) Init(ctx context.Context, date string) error

func (*TransactionRecord) Print added in v0.2.0 

func (r *TransactionRecord) Print(code string, date ...string)

func (*TransactionRecord) Repair added in v0.2.0 

func (r *TransactionRecord) Repair(date string)

func (*TransactionRecord) Update added in v0.2.0 

func (r *TransactionRecord) Update(date string)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.