func NewDataProducer(id string, influxClient influx.Client) DataProducer {
	return &defaultDataProducer{
		id, influxClient,
	}
}
NewDataProducer craetes a new DataProducer
package influx
import (
	"fmt"
	"io"
	"log"
	"github.com/timescale/outflux/internal/extraction/influx/idrfconversion"
	influx "github.com/influxdata/influxdb/client/v2"
	"github.com/timescale/outflux/internal/idrf"
)
type DataProducer interface {
	Fetch(*producerArgs) error
}