add object key in src for S3 acquis (#2342)
This commit is contained in:
parent
1295de928a
commit
f9ca14f010
|
@ -433,7 +433,7 @@ func (s *S3Source) readFile(bucket string, key string) error {
|
||||||
l.Time = time.Now().UTC()
|
l.Time = time.Now().UTC()
|
||||||
l.Process = true
|
l.Process = true
|
||||||
l.Module = s.GetName()
|
l.Module = s.GetName()
|
||||||
l.Src = bucket
|
l.Src = bucket + "/" + key
|
||||||
var evt types.Event
|
var evt types.Event
|
||||||
if !s.Config.UseTimeMachine {
|
if !s.Config.UseTimeMachine {
|
||||||
evt = types.Event{Line: l, Process: true, Type: types.LOG, ExpectMode: types.LIVE}
|
evt = types.Event{Line: l, Process: true, Type: types.LOG, ExpectMode: types.LIVE}
|
||||||
|
|
Loading…
Reference in a new issue