fix: pprof ParseToPprof (grafana#2376)

examples/python/simple/Dockerfile

@@ -1,4 +1,4 @@
-FROM python:3.9
+FROM python:3.11
 
 WORKDIR /usr/src/app
 

examples/python/simple/main.py

@@ -1,12 +1,19 @@
 #!/usr/bin/env python3
 
+import logging
 import os
-
 import pyroscope
 
+l = logging.getLogger()
+l.setLevel(logging.DEBUG)
+
+addr = os.getenv("PYROSCOPE_SERVER_ADDRESS") or "http://pyroscope:4040"
+print(addr)
+
 pyroscope.configure(
-	application_name       = "simple.python.app",
-	server_address = "http://pyroscope:4040",
+	application_name = "simple.python.app",
+	server_address = addr,
+	enable_logging = True,
 )
 
 def work(n):

examples/python/simple/requirements.txt

@@ -1 +1 @@
-pyroscope-io==0.7.1
+pyroscope-io==0.8.5

pkg/distributor/distributor.go

@@ -226,15 +226,15 @@ func (d *Distributor) PushParsed(ctx context.Context, req *distributormodel.Push
 		}
 	}
 
-	haveRawPprof := req.RawProfileType == ""
+	haveRawPprof := req.RawProfileType == distributormodel.RawProfileTypePPROF
 	d.bytesReceivedTotalStats.Inc(int64(req.RawProfileSize))
 	d.bytesReceivedStats.Record(float64(req.RawProfileSize))
 	if !haveRawPprof {
 		// if a single profile contains multiple profile types/names (e.g. jfr) then there is no such thing as
 		// compressed size per profile type as all profile types are compressed once together. So we can not count
 		// compressed bytes per profile type. Instead we count compressed bytes per profile.
 		profName := req.RawProfileType // use "jfr" as profile name
-		d.metrics.receivedCompressedBytes.WithLabelValues(profName, tenantID).Observe(float64(req.RawProfileSize))
+		d.metrics.receivedCompressedBytes.WithLabelValues(string(profName), tenantID).Observe(float64(req.RawProfileSize))
 	}
 
 	for _, series := range req.Series {

pkg/distributor/model/push.go

@@ -5,9 +5,14 @@ import (
 	"github.com/grafana/pyroscope/pkg/pprof"
 )
 
+type RawProfileType string
+
+const RawProfileTypePPROF = RawProfileType("pprof")
+const RawProfileTypeJFR = RawProfileType("jfr")
+
 type PushRequest struct {
 	RawProfileSize int
-	RawProfileType string // should be set if not pprof, eg jfr
+	RawProfileType RawProfileType
 
 	Series []*ProfileSeries
 }

pkg/ingester/pyroscope/ingest_handler.go

@@ -172,8 +172,6 @@ func (h ingestHandler) ingestInputFromRequest(r *http.Request) (*ingestion.Inges
 		input.Profile = &pprof.RawProfile{
 			FormDataContentType: contentType,
 			RawData:             b,
-			StreamingParser:     true,
-			PoolStreamingParser: true,
 		}
 	}