Currently this is a toolkit for interacting with the CrowdFlower REST API. It may potentially become a complete Ruby gem for accessing and editing CrowdFlower jobs.
#####Add this line to your application's Gemfile:
$ gem 'crowdflower'
#####Then execute:
$ bundle install
#####Or install it yourself as:
$ gem install crowdflower
#####And require the gem in your ruby file as:
require 'crowdflower'
This gem makes use of CrowdFlower's API. To find your API key, click on your name in the upper right hand corner and select "Account" from the drop down. To create an account click here.
#####Specify your api key directly in your code or store it in a yaml file:
API_KEY = "YOUR_API_KEY"
CrowdFlower.connect!( 'CrowdFlower.yaml' )#####This job is referenced throughout the following examples (must be signed in to view).
require 'crowdflower'
API_KEY = "YOUR_API_KEY"
DOMAIN_BASE = "https://api.crowdflower.com"
CrowdFlower::Job.connect! API_KEY, DOMAIN_BASE
job = CrowdFlower::Job.new(job_id)
job = CrowdFlower::Job.new(418404)require 'crowdflower'
API_KEY = "YOUR_API_KEY"
DOMAIN_BASE = "https://api.crowdflower.com"
CrowdFlower::Job.connect! API_KEY, DOMAIN_BASE
title = "Crowdshop for Shoes!"
job = CrowdFlower::Job.create(title)require 'crowdflower'
API_KEY = "YOUR_API_KEY"
DOMAIN_BASE = "https://api.crowdflower.com"
CrowdFlower::Job.connect! API_KEY, DOMAIN_BASE
job_id = 418404
job_one = CrowdFlower::Job.new(job_id)
# returns a CrowdFlower::Job object
job_two = job_one.copy#####GET: Example job's JSON, which the GET method has access to:
job.stateResponse
{
"id":000000,
"options":{
"logical_aggregation":true,
"track_clones":true,
"include_unfinished":true,
"front_load":false,
"after_gold":10
},
"title":null,
"secret":"redacted",
"project_number":null,
"alias":null,
"judgments_per_unit":3,
"units_per_assignment":5,
"pages_per_assignment":1,
"max_judgments_per_worker":null,
"max_judgments_per_ip":null,
"gold_per_assignment":0,
"minimum_account_age_seconds":null,
"execution_mode":"worker_ui_remix",
"payment_cents":10,
"custom_key":null,
"design_verified":true,
"require_worker_login":null,
"public_data":false,
"variable_judgments_mode":"none",
"max_judgments_per_unit":null,
"expected_judgments_per_unit":null,
"min_unit_confidence":null,
"units_remain_finalized":null,
"auto_order_timeout":null,
"auto_order_threshold":null,
"completed_at":null,
"state":"unordered",
"auto_order":false,
"webhook_uri":null,
"send_judgments_webhook":null,
"language":"en",
"minimum_requirements":null,
"desired_requirements":null,
"order_approved":true,
"max_work_per_network":null,
"copied_from":null,
"created_at":"2014-03-21T03:10:54+00:00",
"updated_at":"2014-03-21T03:10:54+00:00",
"included_countries":[
],
"excluded_countries":[
],
"instructions":"",
"cml":null,
"js":null,
"css":null,
"problem":null,
"confidence_fields":null,
"gold":{
},
"units_count":0,
"golds_count":0,
"judgments_count":0,
"support_email":"jdoe@crowdflower.com",
"crowd_costs":0.0,
"completed":false,
"fields":null
}job.get["css"]
job.get["auto_order"]
job.get["units_remain_finalized"]
job.get["secret"]
job.get["support_email"]
job.get["golds_count"]
job.get["units_count"]
job.get["included_countries"]
job.get["desired_requirements"]
job.get["max_judgments_per_unit"]
job.get["instructions"]
job.get["auto_order_timeout"]
job.get["public_data"]
job.get["project_number"]
job.get["problem"]
job.get["created_at"]
job.get["send_judgments_webhook"]
job.get["expected_judgments_per_unit"]
job.get["design_verified"]
job.get["worker_ui_remix"]
job.get["fields"]
job.get["completed_at"]
job.get["auto_order_threshold"]
job.get["min_unit_confidence"]
job.get["minimum_account_age_seconds"]
job.get["units_per_assignment"]
job.get["execution_mode"]
job.get["max_judgments_per_worker"]
job.get["gold"]
job.get["require_worker_login"]
job.get["pages_per_assignment"]
job.get["title"]
job.get["completed"]
job.get["order_approved"]
job.get["minimum_requirements"]
job.get["max_judgments_per_ip"]
job.get["confidence_fields"]
job.get["gold_per_assignment"]
job.get["alias"]
job.get["id"]
job.get["judgments_count"]
job.get["js"]
job.get["cml"]
job.get["excluded_countries"]
job.get["updated_at"]
job.get["language"]
job.get["state"]
job.get["variable_judgments_mode"]
job.get["custom_key"]
job.get["options"]#####UPLOAD: upload a file to create the data (or units) in your job.
# opts can be used to force an upload
job.upload(filename, type, opts)
job.upload("crowdshopping.csv", "text/csv")#####CHANNELS: http://api.crowdflower.com/v1/jobs/418404/channels
# view all enabled channels and available channels:
job.channels
# view only the enabled ones:
job.channels["enabled_channels"]
# turn on specific channels:
job.enable_channels(channels)
job.enable_channels(["4x4bux_com", "abitback", "aceinnovations"])
# turn off a specific channel (does not take an array like enable_chanels):
job.disable_channel(channel_name)
job.disable_channel("4x4bux_com")#####TAGS: https://api.crowdflower.com/v1/jobs/418404/tags
# add tags
job.add_tags("shoes")
# replace existing tags
job.update_tags(["fun", "glitter", "crowdshop"])
# remove specific tags
job.remove_tags("crowdshop")#####UNITS: http://api.crowdflower.com/v1/jobs/418404/units
unit = CrowdFlower::Unit.new(job)#####UNIT.ALL: View all units or count all units in a job; same result as job.units.
unit.all
unit.all.count#####UNIT.GET: Get info about a unit by passing in the unit's ID.units.
unit.get(unit_id)#####UNIT.PING: Returns the status of all units in a job.
unit.ping#####UNIT.JUDGMENTS: View all judgments for a specific unit by passing in the unit_id.
unit.judgments(unit_id)
unit.judgments(444154130)#####UNIT.CREATE: Create a new unit.
unit.create(data, gold = false)
# normal unit
unit.create("glitter_color"=>"blue")
# test question (gold) unit
unit.create("glitter_color"=>"blue", true)#####UNIT.COPY: Copy an existing unit.
unit.copy(unit_id, job_id, data = {})
unit.copy(444154130, 418404, "glitter_color"=>"blue")#####UNIT.SPLIT: In cases where multiple values are stored in the cells of the same column, you can use the Split Column function to parse the data into two or more columns by specifying a delimiter (most typically a newline character).
unit.split(on, with = ", ")#####UNIT.UPDATE: Update attributes inside of a unit's data hash. ######Note: The info passed to unit.update will completely replace that unit's exisiting data attributes and values. Be sure to include all the needed info for a given unit, even if just updating one attribute. Examples below.
unit.update(unit_id, :data => {"column_name"=>"column_value"})
# Good Example:
unit.update(99999999, :data => {"retailer_url"=>nil, "shoe_type"=>"Booties", "retailer_name"=>nil, "glitter_color"=>"White", "brand_name"=>"Jeffery Campbell", "image"=>"http://bit.ly/1nFX1I8", "shoe_style"=>"Lita"})
# Bad Example (all unit info gets replaced with the glitter_color & value):
unit.update(99999999, :data => {"glitter_color"=>"White"})#####UNIT.MAKE_GOLD: Turn an existing unit into a test question (gold) unit.
unit.make_gold(unit_id)#####UNIT.CANCEL: Cancel a unit.
unit.cancel(unit_id)#####UNIT.DELETE: Delete a unit.
unit.delete(unit_id)#####UNIT.REQUEST_MORE_JUDGMENTS: Pass in the unit id and the number of additional judgments needed.
unit.request_more_judgments(unit_id, nb_judgments = 1)#####ORDER: Set up an order using your job's id.
order = CrowdFlower::Order.new(job)#####ORDER.DEBIT: This is the same as clicking launch from the job dashboard; your job must have at least 5 units and CML form elements for this to work.
order.debit(units_count, [channels])
order.debit(6, ["cf_internal"])#####PAUSE: Can only be called on running jobs.
job.pause#####RESUME: Can only be called on paused or completed jobs.
job.resume#####CANCEL: Can only be called on paused jobs.
job.cancel#####UPDATE: Update any of the JSON attributes that get can access. Scroll up to GET to see the full list of accessible attributes.
job.update
job.update("project_number"=>"PN123")#####DELETE: Delete the entire job.
job.delete#####WORKERS: http://api.crowdflower.com/v1/jobs/418404/workers
worker = CrowdFlower::Worker.new(job)#####WORKER.BONUS: Award a bonus in cents, 200 for $2.00 and optionally, add a message.
worker.bonus(worker_id, amount, reason=nil)
worker.bonus(99999999, 200, "You shoe shop like a pro! Here's a bonus for the awesome answers!")#####WORKER.REJECT: This method is only available to Pro and Enterprise users. Calling worker.reject stops a contributor from completing tasks and removes the contributor's judgments. It is best used when a job is still running as a completed job cannot collect new judgments to replace the rejected ones.
worker.reject(worker_id)
worker.reject(99999999)#####WORKER.NOTIFY: Sends a message to the specified contributor; appears in the contributor's dashboard notifications.
worker.notify(worker_id, message)
worker.notify(99999999, "Thanks for working on this task!")#####WORKER.FLAG: Prevents a contributor from completing a task; judgments remain in their current state and will not be thrown away.
worker.flag(worker_id, reason = nil, persist = false)
worker.flag(99999999, "Flagging worker from this job.")
# persist = true flags the contributor from all of your jobs
worker.flag(worker_id, reason = nil, persist = true)
worker.flag(99999999, "Flaging worker from all my jobs.")#####WORKER.DEFLAG: Removes flag and allows contributor to continue work.
worker.deflag(worker_id, reason)
worker.deflag(99999999, "Worker was mistakenly flagged.")#####JUDGMENTS: http://api.crowdflower.com/v1/jobs/418404/units/judgments
judgment = CrowdFlower::Judgment.new(job)
judgment.all
judgment.get(judgment_id)
judgment.get(9999999999)
# Return every judgment for the given unit
job.units.judgments(unit_id_number)
job.units.judgments(9999999999)#####LEGEND: Returns all the job's CML - http://api.crowdflower.com/v1/jobs/418404/legend
job.legend#####STATUS: Returns a list of JSON unit and judgment attributes.
job.status
job.status["golden_units"]
job.status["all_judgments"]
job.status["tainted_judgments"]
job.status["completed_units_estimate"]
job.status["needed_judgments"]
job.status["all_units"]
job.status["completed_non_gold_estimate"]
job.status["completed_gold_estimate"]
job.status["ordered_units"]#####DOWNLOAD_CSV: Download a zip file containing a CSV or JSON report, depending which one you specify. Below are examples of the available reports:
job.download_csv(type, filename)
job.download_csv(:full, 'full_report.zip')
job.download_csv(:aggregated, 'aggregated_report.zip')
job.download_csv(:source, 'source_report.zip')
job.download_csv(:gold_report, 'gold_report.zip')
job.download_csv(:workset, 'workset_report.zip')
job.download_csv(:json, 'json_report.zip')- Fork the repo: https://github.com/dolores/ruby-crowdflower.git
- Create your topic branch (
git checkout -b my_branch) - Make changes and add tests for those changes
- Commit your changes, making sure not to change the rakefile, version or history (
git commit -am 'Adds cool, new README') - Push to your branch (
git push origin my_branch) - Create an issue with a link to your branch for the pull request
Check out the CrowdFlower Team!
Copyright (c) 2014 CrowdFlower
Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
Please review our Terms and Conditions page for detailed api usage and licensing information.