datasets

package
v0.3.5 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 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 {
	Manifest
}

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) 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 {
	Manifest
	// 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) 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 {
	Manifest
}

DataSafetyScore 个股基本面安全评分 

Deprecated: 废弃

type DataSet 

type DataSet interface {
	cache.Base
	cache.Initialization
	cache.Properties
	cache.DataFile
	// 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 {
	Manifest
}

func (*DataXdxr) Check added in v0.2.3 

func (x *DataXdxr) Check(cacheDate, featureDate string) error

func (*DataXdxr) Checkout added in v0.3.2 

func (x *DataXdxr) Checkout(securityCode, date string)

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) 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 Manifest added in v0.3.5 

type Manifest struct {
	Date string // 日期
	Code string // 证券代码
	// contains filtered or unexported fields
}

Manifest 基础的数据缓存

func (Manifest) GetDate added in v0.3.5 

func (d Manifest) GetDate() string

func (Manifest) GetSecurityCode added in v0.3.5 

func (d Manifest) GetSecurityCode() string

func (Manifest) Key added in v0.3.5 

func (d Manifest) Key() string

func (Manifest) Kind added in v0.3.5 

func (d Manifest) Kind() cache.Kind

func (Manifest) Name added in v0.3.5 

func (d Manifest) Name() string

func (Manifest) Owner added in v0.3.5 

func (d Manifest) Owner() string

func (Manifest) Usage added in v0.3.5 

func (d Manifest) Usage() 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 {
	Manifest
}

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) 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.