diff --git a/src/libsysprof-profile/meson.build b/src/libsysprof-profile/meson.build
index ed4deed7..340cefd5 100644
--- a/src/libsysprof-profile/meson.build
+++ b/src/libsysprof-profile/meson.build
@@ -6,6 +6,7 @@ libsysprof_profile_public_sources = [
   'sysprof-network-usage.c',
   'sysprof-profiler.c',
   'sysprof-recording.c',
+  'sysprof-sampler.c',
   'sysprof-spawnable.c',
 ]
 
@@ -27,6 +28,7 @@ libsysprof_profile_public_headers = [
   'sysprof-network-usage.h',
   'sysprof-profiler.h',
   'sysprof-recording.h',
+  'sysprof-sampler.h',
   'sysprof-spawnable.h',
 ]
 
diff --git a/src/libsysprof-profile/sysprof-profile.h b/src/libsysprof-profile/sysprof-profile.h
index 7a560a98..8ad775e2 100644
--- a/src/libsysprof-profile/sysprof-profile.h
+++ b/src/libsysprof-profile/sysprof-profile.h
@@ -32,6 +32,7 @@ G_BEGIN_DECLS
 # include "sysprof-network-usage.h"
 # include "sysprof-profiler.h"
 # include "sysprof-recording.h"
+# include "sysprof-sampler.h"
 # include "sysprof-spawnable.h"
 #undef SYSPROF_PROFILE_INSIDE
 
diff --git a/src/libsysprof-profile/sysprof-sampler.c b/src/libsysprof-profile/sysprof-sampler.c
new file mode 100644
index 00000000..530ecd80
--- /dev/null
+++ b/src/libsysprof-profile/sysprof-sampler.c
@@ -0,0 +1,408 @@
+/* sysprof-sampler.c
+ *
+ * Copyright 2023 Christian Hergert <chergert@redhat.com>
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * SPDX-License-Identifier: GPL-3.0-or-later
+ */
+
+#include "config.h"
+
+#include "sysprof-instrument-private.h"
+#include "sysprof-perf-event-stream-private.h"
+#include "sysprof-recording-private.h"
+#include "sysprof-sampler.h"
+
+#define N_WAKEUP_EVENTS 149
+
+struct _SysprofSampler
+{
+  SysprofInstrument parent_instance;
+  GPtrArray *perf_event_streams;
+};
+
+struct _SysprofSamplerClass
+{
+  SysprofInstrumentClass parent_class;
+};
+
+G_DEFINE_FINAL_TYPE (SysprofSampler, sysprof_sampler, SYSPROF_TYPE_INSTRUMENT)
+
+static char **
+sysprof_sampler_list_required_policy (SysprofInstrument *instrument)
+{
+  static const char *policy[] = {"org.gnome.sysprof3.profile", NULL};
+
+  return g_strdupv ((char **)policy);
+}
+
+static inline void
+realign (gsize *pos,
+         gsize  align)
+{
+  *pos = (*pos + align - 1) & ~(align - 1);
+}
+
+static void
+sysprof_sampler_add_callback (SysprofCaptureWriter            *writer,
+                              int                              cpu,
+                              const SysprofPerfEventCallchain *sample)
+{
+  const guint64 *ips;
+  guint64 trace[3];
+  int n_ips;
+
+  g_assert (writer != NULL);
+  g_assert (sample != NULL);
+
+  ips = sample->ips;
+  n_ips = sample->n_ips;
+
+  if (n_ips == 0)
+    {
+      if (sample->header.misc & PERF_RECORD_MISC_KERNEL)
+        {
+          trace[0] = PERF_CONTEXT_KERNEL;
+          trace[1] = sample->ip;
+          trace[2] = PERF_CONTEXT_USER;
+
+          ips = trace;
+          n_ips = 3;
+        }
+      else
+        {
+          trace[0] = PERF_CONTEXT_USER;
+          trace[1] = sample->ip;
+
+          ips = trace;
+          n_ips = 2;
+        }
+    }
+
+  sysprof_capture_writer_add_sample (writer,
+                                     sample->time,
+                                     cpu,
+                                     sample->pid,
+                                     sample->tid,
+                                     ips,
+                                     n_ips);
+}
+
+static void
+sysprof_sampler_perf_event_stream_cb (const SysprofPerfEvent *event,
+                                      guint                   cpu,
+                                      gpointer                user_data)
+{
+  SysprofCaptureWriter *writer = user_data;
+  gsize offset;
+  gint64 time;
+
+  g_assert (writer != NULL);
+  g_assert (event != NULL);
+
+  switch (event->header.type)
+    {
+    case PERF_RECORD_COMM:
+      offset = strlen (event->comm.comm) + 1;
+      realign (&offset, sizeof (guint64));
+      offset += sizeof (GPid) + sizeof (GPid);
+      memcpy (&time, event->comm.comm + offset, sizeof time);
+
+      if (event->comm.pid == event->comm.tid)
+        sysprof_capture_writer_add_process (writer,
+                                            time,
+                                            cpu,
+                                            event->comm.pid,
+                                            event->comm.comm);
+
+      break;
+
+    case PERF_RECORD_EXIT:
+      /* Ignore fork exits for now */
+      if (event->exit.tid != event->exit.pid)
+        break;
+
+      sysprof_capture_writer_add_exit (writer,
+                                       event->exit.time,
+                                       cpu,
+                                       event->exit.pid);
+
+      break;
+
+    case PERF_RECORD_FORK:
+      sysprof_capture_writer_add_fork (writer,
+                                       event->fork.time,
+                                       cpu,
+                                       event->fork.ptid,
+                                       event->fork.tid);
+
+      /*
+       * TODO: We should add support for "follow fork" of the GPid if we are
+       *       targetting it.
+       */
+
+      break;
+
+    case PERF_RECORD_LOST:
+      break;
+
+    case PERF_RECORD_MMAP:
+      offset = strlen (event->mmap.filename) + 1;
+      realign (&offset, sizeof (guint64));
+      offset += sizeof (GPid) + sizeof (GPid);
+      memcpy (&time, event->mmap.filename + offset, sizeof time);
+
+      sysprof_capture_writer_add_map (writer,
+                                      time,
+                                      cpu,
+                                      event->mmap.pid,
+                                      event->mmap.addr,
+                                      event->mmap.addr + event->mmap.len,
+                                      event->mmap.pgoff,
+                                      0,
+                                      event->mmap.filename);
+
+      break;
+
+    case PERF_RECORD_READ:
+      break;
+
+    case PERF_RECORD_SAMPLE:
+      sysprof_sampler_add_callback (writer, cpu, &event->callchain);
+      break;
+
+    case PERF_RECORD_THROTTLE:
+    case PERF_RECORD_UNTHROTTLE:
+    default:
+      break;
+    }
+}
+
+typedef struct _Prepare
+{
+  SysprofRecording *recording;
+  SysprofSampler *sampler;
+} Prepare;
+
+static void
+prepare_free (Prepare *prepare)
+{
+  g_clear_object (&prepare->recording);
+  g_clear_object (&prepare->sampler);
+  g_free (prepare);
+}
+
+static DexFuture *
+sysprof_sampler_prepare_fiber (gpointer user_data)
+{
+  Prepare *prepare = user_data;
+  SysprofCaptureWriter *writer;
+  g_autoptr(GDBusConnection) connection = NULL;
+  g_autoptr(GPtrArray) futures = NULL;
+  g_autoptr(GError) error = NULL;
+  struct perf_event_attr attr = {0};
+  guint n_cpu;
+
+  g_assert (prepare != NULL);
+  g_assert (SYSPROF_IS_RECORDING (prepare->recording));
+  g_assert (SYSPROF_IS_SAMPLER (prepare->sampler));
+
+  n_cpu = g_get_num_processors ();
+  futures = g_ptr_array_new_with_free_func (dex_unref);
+  writer = _sysprof_recording_writer (prepare->recording);
+
+  attr.sample_type = PERF_SAMPLE_IP
+                   | PERF_SAMPLE_TID
+                   | PERF_SAMPLE_IDENTIFIER
+                   | PERF_SAMPLE_CALLCHAIN
+                   | PERF_SAMPLE_TIME;
+  attr.wakeup_events = N_WAKEUP_EVENTS;
+  attr.disabled = TRUE;
+  attr.mmap = 1;
+  attr.comm = 1;
+  attr.task = 1;
+  attr.exclude_idle = 1;
+  attr.sample_id_all = 1;
+
+#ifdef HAVE_PERF_CLOCKID
+  attr.clockid = sysprof_clock;
+  attr.use_clockid = 1;
+#endif
+
+  attr.size = sizeof attr;
+
+  attr.type = PERF_TYPE_HARDWARE;
+  attr.config = PERF_COUNT_HW_CPU_CYCLES;
+  attr.sample_period = 1200000;
+
+  if (!(connection = dex_await_object (dex_bus_get (G_BUS_TYPE_SYSTEM), &error)))
+    return dex_future_new_for_error (g_steal_pointer (&error));
+
+  for (guint i = 0; i < n_cpu; i++)
+    g_ptr_array_add (futures,
+                     sysprof_perf_event_stream_new (connection,
+                                                    &attr,
+                                                    i,
+                                                    -1,
+                                                    0,
+                                                    sysprof_sampler_perf_event_stream_cb,
+                                                    sysprof_capture_writer_ref (writer),
+                                                    (GDestroyNotify)sysprof_capture_writer_unref));
+
+  if (!dex_await (dex_future_allv ((DexFuture **)futures->pdata, futures->len), &error))
+    return dex_future_new_for_error (g_steal_pointer (&error));
+
+  for (guint i = 0; i < futures->len; i++)
+    {
+      DexFuture *future = g_ptr_array_index (futures, i);
+      g_autoptr(SysprofPerfEventStream) stream = NULL;
+      g_autoptr(GError) stream_error = NULL;
+
+      if ((stream = dex_await_object (dex_ref (future), &stream_error)))
+        g_ptr_array_add (prepare->sampler->perf_event_streams, g_steal_pointer (&stream));
+    }
+
+  return dex_future_new_for_boolean (TRUE);
+}
+
+static DexFuture *
+sysprof_sampler_prepare (SysprofInstrument *instrument,
+                         SysprofRecording  *recording)
+{
+  SysprofSampler *self = (SysprofSampler *)instrument;
+  Prepare *prepare;
+
+  g_assert (SYSPROF_IS_INSTRUMENT (instrument));
+  g_assert (SYSPROF_IS_RECORDING (recording));
+
+  prepare = g_new0 (Prepare, 1);
+  prepare->recording = g_object_ref (recording);
+  prepare->sampler = g_object_ref (self);
+
+  return dex_scheduler_spawn (NULL, 0,
+                              sysprof_sampler_prepare_fiber,
+                              prepare,
+                              (GDestroyNotify)prepare_free);
+}
+
+typedef struct _Record
+{
+  SysprofRecording *recording;
+  SysprofSampler *sampler;
+  DexFuture *cancellable;
+} Record;
+
+static void
+record_free (Record *record)
+{
+  g_clear_object (&record->recording);
+  g_clear_object (&record->sampler);
+  dex_clear (&record->cancellable);
+  g_free (record);
+}
+
+static DexFuture *
+sysprof_sampler_record_fiber (gpointer user_data)
+{
+  Record *record = user_data;
+
+  g_assert (record != NULL);
+  g_assert (SYSPROF_IS_SAMPLER (record->sampler));
+  g_assert (SYSPROF_IS_RECORDING (record->recording));
+  g_assert (DEX_IS_FUTURE (record->cancellable));
+
+  for (guint i = 0; i < record->sampler->perf_event_streams->len; i++)
+    {
+      SysprofPerfEventStream *stream = g_ptr_array_index (record->sampler->perf_event_streams, i);
+      g_autoptr(GError) error = NULL;
+
+      if (!sysprof_perf_event_stream_enable (stream, &error))
+        g_debug ("%s", error->message);
+      g_debug ("Sampler %d enabled", i);
+    }
+
+  dex_await (dex_ref (record->cancellable), NULL);
+
+  for (guint i = 0; i < record->sampler->perf_event_streams->len; i++)
+    {
+      SysprofPerfEventStream *stream = g_ptr_array_index (record->sampler->perf_event_streams, i);
+      g_autoptr(GError) error = NULL;
+
+      if (!sysprof_perf_event_stream_disable (stream, &error))
+        g_debug ("%s", error->message);
+      else
+        g_debug ("Sampler %d disabled", i);
+    }
+
+  return dex_future_new_for_boolean (TRUE);
+}
+
+static DexFuture *
+sysprof_sampler_record (SysprofInstrument *instrument,
+                        SysprofRecording  *recording,
+                        GCancellable      *cancellable)
+{
+  SysprofSampler *self = (SysprofSampler *)instrument;
+  Record *record;
+
+  g_assert (SYSPROF_IS_INSTRUMENT (instrument));
+  g_assert (SYSPROF_IS_RECORDING (recording));
+  g_assert (!cancellable || G_IS_CANCELLABLE (cancellable));
+
+  record = g_new0 (Record, 1);
+  record->recording = g_object_ref (recording);
+  record->sampler = g_object_ref (self);
+  record->cancellable = dex_cancellable_new_from_cancellable (cancellable);
+
+  return dex_scheduler_spawn (NULL, 0,
+                              sysprof_sampler_record_fiber,
+                              record,
+                              (GDestroyNotify)record_free);
+}
+
+static void
+sysprof_sampler_finalize (GObject *object)
+{
+  SysprofSampler *self = (SysprofSampler *)object;
+
+  g_clear_pointer (&self->perf_event_streams, g_ptr_array_unref);
+
+  G_OBJECT_CLASS (sysprof_sampler_parent_class)->finalize (object);
+}
+
+static void
+sysprof_sampler_class_init (SysprofSamplerClass *klass)
+{
+  GObjectClass *object_class = G_OBJECT_CLASS (klass);
+  SysprofInstrumentClass *instrument_class = SYSPROF_INSTRUMENT_CLASS (klass);
+
+  object_class->finalize = sysprof_sampler_finalize;
+
+  instrument_class->list_required_policy = sysprof_sampler_list_required_policy;
+  instrument_class->prepare = sysprof_sampler_prepare;
+  instrument_class->record = sysprof_sampler_record;
+}
+
+static void
+sysprof_sampler_init (SysprofSampler *self)
+{
+  self->perf_event_streams = g_ptr_array_new_with_free_func (g_object_unref);
+}
+
+SysprofInstrument *
+sysprof_sampler_new (void)
+{
+  return g_object_new (SYSPROF_TYPE_SAMPLER, NULL);
+}
diff --git a/src/libsysprof-profile/sysprof-sampler.h b/src/libsysprof-profile/sysprof-sampler.h
new file mode 100644
index 00000000..4a7309b7
--- /dev/null
+++ b/src/libsysprof-profile/sysprof-sampler.h
@@ -0,0 +1,42 @@
+/* sysprof-sampler.h
+ *
+ * Copyright 2023 Christian Hergert <chergert@redhat.com>
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * SPDX-License-Identifier: GPL-3.0-or-later
+ */
+
+#pragma once
+
+#include "sysprof-instrument.h"
+
+G_BEGIN_DECLS
+
+#define SYSPROF_TYPE_SAMPLER         (sysprof_sampler_get_type())
+#define SYSPROF_IS_SAMPLER(obj)      G_TYPE_CHECK_INSTANCE_TYPE(obj, SYSPROF_TYPE_SAMPLER)
+#define SYSPROF_SAMPLER(obj)         G_TYPE_CHECK_INSTANCE_CAST(obj, SYSPROF_TYPE_SAMPLER, SysprofSampler)
+#define SYSPROF_SAMPLER_CLASS(klass) G_TYPE_CHECK_CLASS_CAST(klass, SYSPROF_TYPE_SAMPLER, SysprofSamplerClass)
+
+typedef struct _SysprofSampler      SysprofSampler;
+typedef struct _SysprofSamplerClass SysprofSamplerClass;
+
+SYSPROF_AVAILABLE_IN_ALL
+GType              sysprof_sampler_get_type (void) G_GNUC_CONST;
+SYSPROF_AVAILABLE_IN_ALL
+SysprofInstrument *sysprof_sampler_new      (void);
+
+G_DEFINE_AUTOPTR_CLEANUP_FUNC (SysprofSampler, g_object_unref)
+
+G_END_DECLS
diff --git a/src/libsysprof-profile/tests/test-profiler.c b/src/libsysprof-profile/tests/test-profiler.c
index ba4b1364..a57adbee 100644
--- a/src/libsysprof-profile/tests/test-profiler.c
+++ b/src/libsysprof-profile/tests/test-profiler.c
@@ -120,6 +120,7 @@ main (int       argc,
   sysprof_profiler_add_instrument (profiler, sysprof_disk_usage_new ());
   sysprof_profiler_add_instrument (profiler, sysprof_memory_usage_new ());
   sysprof_profiler_add_instrument (profiler, sysprof_network_usage_new ());
+  sysprof_profiler_add_instrument (profiler, sysprof_sampler_new ());
 
   for (int i = 1; i < argc; i++)
     {