# algorithm_scheduling

algorithm_code: 1
algorithm_name: 接收ibmq数据
service_code: 1001
class_name: com.bfkj.unidia.IOUtils.IBMMQHelper
method_name: receiveMessage
description: 接收ibmq
input_data_template:
{
  "mqConfig": {
    "host": "192.168.52.130",
		"userId":"mquser",
		"password":"mquser",
    "port": 13133,
    "channel": "server_channel",
    "queueManager": "mmq_kafka_manager",
    "sendQueueName": "recv",
    "ccsid": 819,
    "receiveTimeout": 300
  },
  "queueName": "recv",
  "maxMessages": 100
}


algorithm_code: 2
algorithm_name: 发送原始报文给Kafka
service_code: 1001
class_name: com.bfkj.unidia.IOUtils.KafkaHelper
method_name: send
description: 将原始报文发送给kafka
input_data_template:
{
  "kafkaConfig": {
    "bootstrap.servers": "localhost:9092"
  },
  "topic": "raw_message_input",
  "data": "@1.returnData"
}


algorithm_code: 3
algorithm_name: Kafka消费数据
service_code: 1002
class_name: com.bfkj.unidia.IOUtils.KafkaHelper
method_name: consume
description: 从Kafka消费数据
input_data_template:
{
  "kafkaConfig": {
    "bootstrap.servers": "localhost:9092"
  },
  "topic": "raw_message_input",
  "groupId": "%algorithm_code",
  "maxRecords": 100
}


algorithm_code: 5
algorithm_name: 转换数据
service_code: 1002
input_data_template: {"data":"@4.returnData"}
description: js转换解析出的json
method_name:
xmlToJson(data)
function xmlToJson(jsonStr) {
         console.log("=========================>")
         console.log(jsonStr)
}


