Skip to content

[Logs] Add timestamp field to log envelope item #4553

@AbhiPrasad

Description

@AbhiPrasad

https://github.com/getsentry/relay/blob/master/relay-server/src/services/processor/ourlog.rs#L53-L71

Need to update otel_to_sentry_log
https://github.com/getsentry/relay/blob/master/relay-ourlogs/src/ourlog.rs#L8

and adjust OurLog (with timestamp not in nanos) to LogKafkaMessage (has to be in nanos)

let mut log: LogKafkaMessage = match serde_path_to_error::deserialize(d) {
Ok(log) => log,
Err(error) => {
relay_log::error!(
error = &error as &dyn std::error::Error,
"failed to parse log"
);
self.outcome_aggregator.send(TrackOutcome {
category: DataCategory::LogItem,
event_id: None,
outcome: Outcome::Invalid(DiscardReason::InvalidLog),
quantity: 1,
remote_addr: None,
scoping,
timestamp: received_at,
});
self.outcome_aggregator.send(TrackOutcome {
category: DataCategory::LogByte,
event_id: None,
outcome: Outcome::Invalid(DiscardReason::InvalidLog),
quantity: payload.len() as u32,
remote_addr: None,
scoping,
timestamp: received_at,
});
return Ok(());
}
};

Metadata

Metadata

Assignees

Labels

No labels
No labels

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions