1207348 - Work with v4-from-5%-of-release data to make it easily available to Metrics team

Status: RESOLVED FIXED

(Toolkit :: Telemetry, defect, P2)

Comment 1

[Sam Penrose]

On Spark:

from moztelemetry import get_pings
# All of these parameters except schema are mandatory;
# you can add other kwargs such as fraction.
v4 = get_pings(sc, channel='release', version='41.0', schema='v4', doc_type='main')

def in_sample(d):
    return d.get('environment', {}).get('settings', {}).get('isInOptoutSample')

valid = v4.filter(in_sample)

# If you want the inverse, you have to test for "is False" as
# a missing value will result in None, which is false-y in Python
invalid = v4.filter(lambda d: in_sample(d) is False)

Please reopen if you want another API.