254 个回答
在python中怎么建库建表
import dolphindb as ddb s = ddb.session() s.connect("127.0.0.1", 8848,"admin","123456") dbName="dfs://forwardtekDdb2" tableName='windTurbine' script=""" dbName='{db}' if(exists(dbName)) dropDatabase(dbName) tableSchema = table(100:0,`id`tm`val,[INT,DATETIME,FLOAT]); db1 = database("",VALUE,2...
回答于 2021-05-20 10:50
update！时报错列数据类型不匹配
update!(factor, i, i + 10)中i是字符串，i+10就是一个字符串，不是一个字段，所以可改成： update!(factor, i, factor[i] + 10) 或者 factor[i] = factor[i] + 10 或者 update!(factor, i, expr(sqlCol(i), +, 10))
回答于 2021-05-20 10:50
请问在DolphinDB中有类似python winsorize这样的函数吗
可自定义函数实现，代码如下： def winsorize(x, downPercentile, upPercentile){ uplimit = percentile(x, upPercentile) downlimit = percentile(x, downPercentile) return iif(x > uplimit, uplimit, iif(x < downlimit, downlimit, x)) } x= rand(1.0, 1000000) y = winsorize(x, 5, 95)
回答于 2021-05-20 10:50
从hdf5文件导入数据时如何把整数转换成时间？
新版本hdf5插件hdf5::loadHDF5Ex函数提供了一个transform参数，在将数据导入数据库之前，若需要对数据进行预处理，例如转换日期和时间数据类型，填充空值等，可以在hdf5::loadHDF5Ex函数时指定transform参数。tansform参数接受一个函数作为参数，并且要求该函数只能接受一个参数。函数的输入是一个未分区的内存表，输出也是...
回答于 2021-05-20 10:49
DolphinDB如何安全的关机
DolphinDB对分布式数据库表的读写支持事务，保证多行写入数据（可以跨越多个分区，支持多个副本）的原子性和持久性。断电/kill -9不影响写入的数据，也不破坏数据库的完整性。
回答于 2021-05-20 10:47
问下context by 怎么加到update!里面去
DolphinDB有个contextby函数（https://www.dolphindb.cn/cn/h... ），其语法为 contextby(func, funcArgs, groupingCol, [sortingCol])，可根据groupingCol分组，并在组内进行func(funcArgs)运算。代码如下，其中factors[j]就是factor2： factors[i] = contextby(def(x,y){return x - dot(x,y)/sum2(y)*y}, [factors[i], f...
回答于 2021-05-20 10:47
如何导入没有列名的txt数据文件
还有一个办法，获得了schema之后，修改一下schema中的列名。 schema=extractTextSchema(fileName) schema[`name] = `TradeDate`Type`Seq ... `TradeFlag
回答于 2021-05-20 10:45
官网的示例代码为何异常？
这个看起来是没有try catch conn.connect这段代码。这段代码可能抛出异常，没有捕获就会导致程序崩溃。你捕获一下异常，看看异常原因是什么
回答于 2021-05-20 10:44
csv格式的tick行情数据导入分布式表时时间类型怎么转换
这个需要进行类型转换。比如可以在 read_csv() 方法中，通过 parse_dates 参数直接将某些列转换成 datetime64 类型: csv_data=pd.read_csv(csv_file,dtype={'symbol':str},parse_dates=['date','time'])
回答于 2021-05-20 10:42
怎么快速计算最近1000个shares的vwap
defg lastVolPx(price, vol, bound){ cumVol = vol.cumsum() if(cumVol.tail() <= bound) return wavg(price, vol) else{ start = (cumVol <= cumVol.tail() - bound).sum() return wavg(price.subarray(start:), vol.subarray(start:)) } } n = 5000000 t =table(rand(st...
回答于 2021-05-20 10:39