Method updateLogRecord

module/log/iml.go:361–399

(ctx context.Context, driver log_driver.ILogDriver, start, end time.Time)

}

func (i *imlLogModule) updateLogRecord(ctx context.Context, driver log_driver.ILogDriver, start, end time.Time) error {
	c, err := i.clusterService.Get(ctx, cluster.DefaultClusterID)
	if err != nil {
		return fmt.Errorf("cluster %s not found", cluster.DefaultClusterID)
	}
	logs, err := driver.LogRecords(c.Cluster, start, end)
	if err != nil {

		return fmt.Errorf("get log records error: %s", err)
	}
	for _, l := range logs {
		err = i.service.InsertLog(ctx, "loki", &log.InsertLog{
			ID:            l.ID,
			Driver:        "loki",
			Strategy:      l.Strategy,
			API:           l.API,
			Service:       l.Service,
			Method:        l.Method,
			Url:           l.Url,
			RemoteIP:      l.RemoteIP,
			Consumer:      l.Consumer,
			Authorization: l.Authorization,
			InputToken:    l.InputToken,
			OutputToken:   l.OutputToken,
			TotalToken:    l.TotalToken,
			AIProvider:    l.AIProvider,
			AIModel:       l.AIModel,
			StatusCode:    l.StatusCode,
			ResponseTime:  l.ResponseTime,
			Traffic:       l.Traffic,
			RecordTime:    l.RecordTime,
		})
		if err != nil {
			eosc_log.Errorf("insert log record error: %s,log id: %s", err, l.ID)
			continue
		}
	}
	return nil
}