Sha256: a006f386171917213f2927d8f460a533f6fd1a0fffaeddf110af1d4156edcbd0
Contents?: true
Size: 1.98 KB
Versions: 9
Compression:
Stored size: 1.98 KB
Contents
module JIJI
module Service
class OutputService
# 指定範囲の出力データを取得する。
def list_datas( process_id, names, scale, start_time, end_time )
p = process_manager.get( process_id )
list = {}
names.each {|n|
buff = []
outputs = p.outputs[n[0]]
next unless outputs
outputs.get(n[1]).each( scale,
Time.at(start_time), Time.at(end_time) ) {|data|
buff << data
}
list[n[0]] = {} if !list[n[0]]
list[n[0]][n[1]] = buff
}
return list
end
# プロセスの出力一覧を取得する
def list_outputs( process_id )
p = process_manager.get( process_id )
return p.outputs.inject({}) {|buff,item|
buff[item[0]] = item[1].inject({}) {|r,v|
r[v[0]] = v[1].options
r
}
buff
}
end
# アウトプットのプロパティを設定
def set_properties( process_id, name, properties )
p = process_manager.get( process_id )
outputs = p.outputs[name[0]]
raise UserError.new( JIJI::ERROR_NOT_FOUND, "output not found. name=#{name[0]}") unless outputs
out = outputs.get(name[1])
raise UserError.new( JIJI::ERROR_NOT_FOUND, "output not found. name=#{name[0]}:#{name[1]}") unless out
out.set_properties( properties )
return :success
end
# プロセスのログを取得する
def get_log( process_id )
process_manager.get( process_id ) # プロセスの存在確認
file = "#{@process_dir}/#{process_id}/log.txt" # TODO 古いものも連結するか? サイズが大きくなってしまうので微妙。
if ( File.exist?( file ) )
return IO.read( file )
else
return ""
end
end
attr :process_dir, true
attr :process_manager, true
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems