while ( my $record = $sth->fetch() ) {
  $runner->run(... feed record to service ...);
}