gistfile1.txt

#!/opt/puppetlabs/puppet/bin/ruby

require "mcollective"

include MCollective::RPC

c = rpcclient("rpcutil")


# you'd read your file here or something to get the nodes list
nodes = c.discover

# your arguments to the agent goes in the hash here
req = c.new_request("ping", {})

reqid = nil

# 10 is the batch size
nodes.in_groups_of(10) do |nodes|
  message = MCollective::Message.new(req, nil, :agent => "rpcutil",
                                               :type => :direct_request,
                                               :collective => "mcollective",
                                               :filter => MCollective::Util.empty_filter,
                                               :options => c.options)
  reqid ||= message.create_reqid
  message.requestid = reqid

  message.discovered_hosts = nodes.clone.compact
  message.reply_to = "some.reply.target"

  puts "Sending to %d nodes" % message.discovered_hosts.size
  pp message.discovered_hosts

  c.client.sendreq(message, nil)

  # aadjust the sleep to your tastes
  sleep 10
end