nmc_message_client

README

nmc-message-client

A message client for NWPC operation systems.

Installing

Download the latest release and build source code.

Use Makefile to build source code on Linux.

All tools will be installed in bin directory.

Getting started

Use different tools to send messages to different message system.

nmc_monitor_client

Send message to NMC Monitor Platform using nmc_monitor_client send command.

nmc_monitor_client send \
	--target 10.20.67.183:9092,10.20.67.216:9092,10.20.67.217:9092 \
	--source nwpc_grapes_gfs \
	--type prod_grib \
	--status 0 \
	--file-name gmf.gra.2019062400006.grb2 \
	--absolute-data-name /g2/nwp_pd/NWP_PST_DATA/GMF_GRAPES_GFS_POST/togrib2/output_togrib2/2019062400/gmf.gra.2019062400006.grb2 \
	--start-time 2019062400 \
	--forecast-time 006 \
	--debug

The command above will send message below to NMC Monitor Platform's kafka server (10.20.90.35:9092) with default topic monitor.

{
	"source":"nwpc_grapes_gfs",
	"type":"prod_grib",
	"status":"0",
	"datetime":1561363080430,
	"fileName":"gmf.gra.2019062400006.grb2",
	"absoluteDataName":"/g2/nwp_pd/NWP_PST_DATA/GMF_GRAPES_GFS_POST/togrib2/output_togrib2/2019062400/gmf.gra.2019062400006.grb2",
	"desc":"{\"start_time\":\"2019062400\",\"forecast_time\":\"006\"}"
}

License

Copyright © 2019-2020, Perilla Roc at nwpc-oper.

nmc-message-client is licensed under MIT License

Documentation

Index

• func CreateProdGribMessage(source string, messageType string, status string, datetime int64, ...) ([]byte, error)
• func CreateProductMessage(topic string, source string, sourceIP string, messageType string, ...) ([]byte, error)
• type GribProduction
• type MonitorMessage
• type MonitorMessageV2
• type ProbGribMessageDescription

Functions

func CreateProdGribMessage

func CreateProdGribMessage(
	source string,
	messageType string,
	status string,
	datetime int64,
	fileName string,
	absoluteDataName string,
	startTime string,
	forecastTime string) ([]byte, error)

func CreateProductMessage

func CreateProductMessage(
	topic string,
	source string,
	sourceIP string,
	messageType string,
	dateTime time.Time,
	fileName string,
	absoluteDataName string,
	fileSize int64,
	productIntervalHour int32,
	status int8,
	startTime string,
	forecastTime string,
) ([]byte, error)

Types

type GribProduction

type GribProduction struct {
	Offset       string    `json:"-"`
	Source       string    `json:"source"`
	MessageType  string    `json:"type"`
	Status       int8      `json:"status"`
	DateTime     time.Time `json:"datetime,omitempty"`
	FileName     string    `json:"fileName"`
	StartTime    time.Time `json:"startTime,omitempty"`
	ForecastTime string    `json:"forecastTime,omitempty"`
}

type MonitorMessage

type MonitorMessage struct {
	Source           string `json:"source"`
	MessageType      string `json:"type"`
	Status           string `json:"status"`
	DateTime         int64  `json:"datetime,omitempty"`
	FileName         string `json:"fileName"`
	AbsoluteDataName string `json:"absoluteDataName,omitempty"`
	Description      string `json:"desc,omitempty"`
}

type MonitorMessageV2

type MonitorMessageV2 struct {
	Topic             string `json:"topic"`
	Source            string `json:"source"`
	SourceIP          string `json:"sourceIP"`
	MessageType       string `json:"type"`
	PID               string `json:"PID"`
	ID                string `json:"ID"`
	DateTime          string `json:"datetime,omitempty"`
	FileNames         string `json:"fileNames"`
	AbsoluteDataName  string `json:"absoluteDataName,omitempty"`
	FileSizes         string `json:"fileSizes"`
	Result            int8   `json:"result"`
	ResultDescription string `json:"resultDesc"`
}

type ProbGribMessageDescription

type ProbGribMessageDescription struct {
	StartTime    string `json:"startTime,omitempty"`
	ForecastTime string `json:"forecastTime,omitempty"`
}