我有一张 table :
CREATE TABLE "public"."ParamValueBlock" (
"ParameterId" int2 NOT NULL,
"DeviceId" int2 NOT NULL,
"CompressedData" bytea,
"StartDate" int4 NOT NULL,
"UncompressedDataBits" int4 NOT NULL
)
这是我批量复制到数据库的代码:
connectionString := fmt.Sprintf("host=%s port=%d user=%s "+
"password=%s dbname=%s sslmode=disable",
host, port, user, password, dbname)
db, err := sql.Open("postgres", connectionString)
if err != nil {
return err
}
defer db.Close()
tx, err := db.BeginTx(context.Background(), &sql.TxOptions{Isolation: sql.LevelReadCommitted, ReadOnly: false})
if err != nil {
return err
}
stmt, err := tx.Prepare(`COPY "ParamValueBlock" ("ParameterId", "DeviceId", "CompressedData", "StartDate", "UncompressedDataBits") FROM STDIN;`)
if err != nil {
return err
}
for _, item := range items{
_, err := stmt.Exec(
int16(item.paramID),
1,
item.dataBuffer,
item.secondsSince2015,
int32(item.uncompressedBitsSize))
if err != nil {
tx.Rollback()
return err
}
}
err = stmt.Close()
if err != nil {
tx.Rollback()
return err
}
err = tx.Commit()
if err != nil {
return err
}
return nil
我正在写 1000 个项目(1 个项目 = 28KB),这是 7 秒。
为什么这么慢,我该如何优化它?
如果是来自文件:
COPY "ParamValueBlock" FROM 'C:\Temp\x.txt' (FORMAT text);
时间是0.7秒
配置文件cpu:
flat flat% sum% cum cum%
1.82s 31.06% 31.06% 1.83s 31.23% runtime.cgocall
0.35s 5.97% 37.03% 0.36s 6.14% ...pq.appendEscapedText
0.30s 5.12% 42.15% 0.76s 12.97% fmt.(*fmt).fmtInteger
0.30s 5.12% 47.27% 1.53s 26.11% fmt.(*pp).doPrintf
0.14s 2.39% 67.92% 2.98s 50.85% fmt.Sprintf
0.11s 1.88% 76.11% 0.97s 16.55% fmt.(*pp).printArg
0.10s 1.71% 77.82% 0.19s 3.24% fmt.(*buffer).Write (inline)
0.09s 1.54% 79.35% 0.85s 14.51% fmt.(*pp).fmtInteger
0.09s 1.54% 80.89% 3.26s 55.63% github.com/lib/pq.encodeBytea
0.01s 0.17% 94.37% 5.20s 88.74% github.com/lib/pq.(*copyin).Exec
最佳答案
这是 pg 驱动程序错误:https://github.com/lib/pq/pull/784
我将 github.com/lib/pq 替换为 github.com/jackc/pgx/stdlib 并在 postgresql.conf<>:
autovacuum_vacuum_scale_factor = 0.0
autovacuum_vacuum_threshold = 5000
autovacuum_analyze_scale_factor = 0.0
autovacuum_analyze_threshold = 5000
synchronous_commit = off
wal_level = 'minimal'
archive_mode = off
max_wal_senders = 0
并将插入速度提高 60%
附加信息
PREPARE 和 INSERT 或 COPYStmt 必须在 交易后关闭COPY 仅通过 native (无 stdlib)接口(interface)支持。你可以
使用 AcquireConn 和 ReleaseConn 从
数据库/SQL 池。我插入多行的示例:
func InsertParamValueBlocks(params []model.ParamValueBlock) error {
var dbWrk db.Worker
var stmt *sql.Stmt
var err error
result := dbWrk.DoInTransaction(sql.LevelDefault, func() error {
stmt, err = dbWrk.Context.Prepare(`INSERT INTO "ParamValueBlock" ("ParameterId", "DeviceId", "CompressedData", "StartDate", "UncompressedDataBits")VALUES ($1, $2, $3, $4, $5);`)
if err != nil {
return err
}
for _, param := range params {
_, err := stmt.Exec(
param.ParameterID,
param.DeviceID,
param.CompressedData,
param.StartDate,
param.UncompressedDataBits)
if err != nil {
return err
}
}
return nil
})
//stmt close after transaction
err = stmt.Close()
if err != nil {
return err
}
return result
}
关于postgresql - COPY 命令运行缓慢,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53480845/
总的来说,我对ruby还比较陌生,我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础,我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用
我想用ruby编写一个小的命令行实用程序并将其作为gem分发。我知道安装后,Guard、Sass和Thor等某些gem可以从命令行自行运行。为了让gem像二进制文件一样可用,我需要在我的gemspec中指定什么。 最佳答案 Gem::Specification.newdo|s|...s.executable='name_of_executable'...endhttp://docs.rubygems.org/read/chapter/20 关于ruby-在Ruby中编写命令行实用程序
在选择我想要运行操作的频率时,唯一的选项是“每天”、“每小时”和“每10分钟”。谢谢!我想为我的Rails3.1应用程序运行调度程序。 最佳答案 这不是一个优雅的解决方案,但您可以安排它每天运行,并在实际开始工作之前检查日期是否为当月的第一天。 关于ruby-如何每月在Heroku运行一次Scheduler插件?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/8692687/
exe应该在我打开页面时运行。异步进程需要运行。有什么方法可以在ruby中使用两个参数异步运行exe吗?我已经尝试过ruby命令-system()、exec()但它正在等待过程完成。我需要用参数启动exe,无需等待进程完成是否有任何rubygems会支持我的问题? 最佳答案 您可以使用Process.spawn和Process.wait2:pid=Process.spawn'your.exe','--option'#Later...pid,status=Process.wait2pid您的程序将作为解释器的子进程执行。除
我尝试运行2.x应用程序。我使用rvm并为此应用程序设置其他版本的ruby:$rvmuseree-1.8.7-head我尝试运行服务器,然后出现很多错误:$script/serverNOTE:Gem.source_indexisdeprecated,useSpecification.Itwillberemovedonorafter2011-11-01.Gem.source_indexcalledfrom/Users/serg/rails_projects_terminal/work_proj/spohelp/config/../vendor/rails/railties/lib/r
Sinatra新手;我正在运行一些rspec测试,但在日志中收到了一堆不需要的噪音。如何消除日志中过多的噪音?我仔细检查了环境是否设置为:test,这意味着记录器级别应设置为WARN而不是DEBUG。spec_helper:require"./app"require"sinatra"require"rspec"require"rack/test"require"database_cleaner"require"factory_girl"set:environment,:testFactoryGirl.definition_file_paths=%w{./factories./test/
这里有一个很好的答案解释了如何在Ruby中下载文件而不将其加载到内存中:https://stackoverflow.com/a/29743394/4852737require'open-uri'download=open('http://example.com/image.png')IO.copy_stream(download,'~/image.png')我如何验证下载文件的IO.copy_stream调用是否真的成功——这意味着下载的文件与我打算下载的文件完全相同,而不是下载一半的损坏文件?documentation说IO.copy_stream返回它复制的字节数,但是当我还没有下
GivenIamadumbprogrammerandIamusingrspecandIamusingsporkandIwanttodebug...mmm...let'ssaaay,aspecforPhone.那么,我应该把“require'ruby-debug'”行放在哪里,以便在phone_spec.rb的特定点停止处理?(我所要求的只是一个大而粗的箭头,即使是一个有挑战性的程序员也能看到:-3)我已经尝试了很多位置,除非我没有正确测试它们,否则会发生一些奇怪的事情:在spec_helper.rb中的以下位置:require'rubygems'require'spork'
是否有可能:before_filter:authenticate_user!||:authenticate_admin! 最佳答案 before_filter:do_authenticationdefdo_authenticationauthenticate_user!||authenticate_admin!end 关于ruby-on-rails-before_filter运行多个方法,我们在StackOverflow上找到一个类似的问题: https://
之前在培训新生的时候,windows环境下配置opencv环境一直教的都是网上主流的vsstudio配置属性表,但是这个似乎对新生来说难度略高(虽然个人觉得完全是他们自己的问题),加之暑假之后对cmake实在是爱不释手,且这样配置确实十分简单(其实都不需要配置),故斗胆妄言vscode下配置CV之法。其实极为简单,图比较多所以很长。如果你看此文还配不好,你应该思考一下是不是自己的问题。闲话少说,直接开始。0.CMkae简介有的人到大二了都不知道cmake是什么,我不说是谁。CMake是一个开源免费并且跨平台的构建工具,可以用简单的语句来描述所有平台的编译过程。它能够根据当前所在平台输出对应的m