Плагин Grails Mahout с фоновым заданием (quartz2)

Question

Я новичок в Grails. Я использую плагин Mahout Recommender для создания движка Recommender. Я следую этому уроку. Он отлично работает для меня.

Теперь, что я пытаюсь сделать, я просто хочу сделать эту Рекомендацию Mahout, используя Background JOB. Так что пользователь может рекомендовать автоматически на основе того, что ему нравится. Я использую Quartz 2.x Scheduler для фоновой работы. Как я могу использовать Mahout в качестве фона JOB?

В этом уроке вы можете видеть, что я создал один PrefrenceController.groovy, в который я добавляю userID, itemID и номер prefrence.

Мой файл класса домена Prefrence.groovy -

package com.rbramley.mahout

import org.apache.commons.lang.builder.HashCodeBuilder

class Preference implements Serializable {
   long userId
   long itemId
   float prefValue

   static constraints = {
       userId()
       itemId()
       prefValue range: 0.0f..5.0f
   }

   boolean equals(other) {
      if(!(other instanceof Preference)) {
         return false
      }

    other.userId == userId && other.itemId == itemId
   }

   int hashCode() {
      def builder = new HashCodeBuilder()
      builder.append userId
      builder.append itemId
      builder.toHashCode()
   }

   static mapping = {
      id composite: ['userId', 'itemId']
      version false
   }
  }

и мой PrefrenceController.groovy

package com.rbramley.mahout

import org.springframework.dao.DataIntegrityViolationException

class PreferenceController {

   static allowedMethods = [save: "POST", update: "POST", delete: "POST"]

   def index() {
       redirect(action: "list", params: params)
   }

   def list(Integer max) {
      params.max = Math.min(max ?: 10, 100)
      [preferenceInstanceList: Preference.list(params), preferenceInstanceTotal: Preference.count()]
   }

   def create() {
       [preferenceInstance: new Preference(params)]
   }

   def save() {
       def preferenceInstance = new Preference(params)
       if (!preferenceInstance.save(flush: true)) {
          render(view: "create", model: [preferenceInstance: preferenceInstance])
          return
       }

    flash.message = message(code: 'default.created.message', args: [message(code: 'preference.label', default: 'Preference'), preferenceInstance.id])
    redirect(action: "show", id: preferenceInstance.id)
    }

    def show(Long id) {
      def preferenceInstance = Preference.get(id)
      if (!preferenceInstance) {
        flash.message = message(code: 'default.not.found.message', args: [message(code: 'preference.label', default: 'Preference'), id])
        redirect(action: "list")
        return
    }

    [preferenceInstance: preferenceInstance]
  }

  def edit(Long id) {
    def preferenceInstance = Preference.get(id)
    if (!preferenceInstance) {
        flash.message = message(code: 'default.not.found.message', args: [message(code: 'preference.label', default: 'Preference'), id])
        redirect(action: "list")
        return
    }

    [preferenceInstance: preferenceInstance]
  }

  def update(Long id, Long version) {
    def preferenceInstance = Preference.get(id)
    if (!preferenceInstance) {
        flash.message = message(code: 'default.not.found.message', args: [message(code: 'preference.label', default: 'Preference'), id])
        redirect(action: "list")
        return
    }

    if (version != null) {
        if (preferenceInstance.version > version) {
            preferenceInstance.errors.rejectValue("version", "default.optimistic.locking.failure",
                      [message(code: 'preference.label', default: 'Preference')] as Object[],
                      "Another user has updated this Preference while you were editing")
            render(view: "edit", model: [preferenceInstance: preferenceInstance])
            return
        }
    }

    preferenceInstance.properties = params

    if (!preferenceInstance.save(flush: true)) {
        render(view: "edit", model: [preferenceInstance: preferenceInstance])
        return
    }

    flash.message = message(code: 'default.updated.message', args: [message(code: 'preference.label', default: 'Preference'), preferenceInstance.id])
    redirect(action: "show", id: preferenceInstance.id)
}

def delete(Long id) {
    def preferenceInstance = Preference.get(id)
    if (!preferenceInstance) {
        flash.message = message(code: 'default.not.found.message', args: [message(code: 'preference.label', default: 'Preference'), id])
        redirect(action: "list")
        return
    }

    try {
        preferenceInstance.delete(flush: true)
        flash.message = message(code: 'default.deleted.message', args: [message(code: 'preference.label', default: 'Preference'), id])
        redirect(action: "list")
    }
    catch (DataIntegrityViolationException e) {
        flash.message = message(code: 'default.not.deleted.message', args: [message(code: 'preference.label', default: 'Preference'), id])
        redirect(action: "show", id: id)
    }
}
}

Предположим, я добавил некоторые данные вручную в свою базу данных. Теперь, когда пользователь нажимает на RecomController и вводит определенный идентификатор пользователя, тогда он будет показывать рекомендации. Но я хочу сделать это в качестве фона работы. Рекомендация должна предлагаться автоматически всем пользователям без вмешательства человека.

Answer 1

Если я понял ваш вопрос, вам нужна работа по требованию, чтобы вы могли запустить ее с вашего контроллера. Для этого создайте задание без какого-либо триггера, затем вы можете запустить его вручную с вашего контроллера и передать в него свои параметры. Это вызовет работу на заднем плане. В программе execute определить, что нужно сделать для работы, вы также можете внедрить в эту работу любые услуги, которые вам нужны.

контроллер:

BackgroundJob.triggerNow([id:params.id,userId:userId]) 

работа

class BackgroundJob {
    static triggers = {}

    def execute(context) {
        def id = context.mergedJobDataMap.get('id')
        def userId = context.mergedJobDataMap.get('userId')
        ...
    }
}