t-nakata
March 13, 2020, 6:10am
1
logstashでどこまでファイルを読み込んだかを記録するincedbがあると思います。
(sincedb出力例)
tsgkdt
March 13, 2020, 1:10pm
2
困ったときのソース頼み、ということでLogstashのリポジトリで、フォーマットに関するコメントがあるところを紹介します。
end
def deserialize_record(record)
return [] if record.nil? || record.empty?
parts = record.split(" ")
parse_line_v2(parts) || parse_line_v1(parts)
end
private
def parse_line_v2(parts)
# new format e.g. 2977152 1 4 94 1519319662.852678 'path/to/file'
# do we want to store the last known state of the watched file too?
return false if parts.size < 5
inode_struct = prepare_inode_struct(parts)
pos = parts.shift.to_i
expires_at = Float(parts.shift) # this is like Time.now.to_f
path_in_sincedb = parts.join(" ")
value = SincedbValue.new(pos, expires_at).add_path_in_sincedb(path_in_sincedb)
[inode_struct, value]
end
ここで、提示されているsincedbの出力例にあうような文字が書かれています。
# new format e.g. 2977152 1 4 94 1519319662.852678 'path/to/file'
Rubyは全然わからないので何とも言えませんが、inode, position, expire時間, パスに関して書かれているように見受けられます。
こちらのソースを確認してみてはどうでしょうか？
system
April 10, 2020, 1:10pm
3
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.