package etl
|
|
|
|
import (
|
|
model "LAPP_ETL/models/etl"
|
|
"LAPP_ETL/services/etl/implments"
|
|
)
|
|
|
|
/******************************************************************************
|
|
*
|
|
* @Interface Name : ExtractService
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : ExtractService的服务接口
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-06-02
|
|
*
|
|
******************************************************************************/
|
|
type ExtractService interface {
|
|
/******************************************************************************
|
|
*
|
|
* @Function Name : StandardExtract
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : 抽取数据到mongo
|
|
*
|
|
* @Function Parameters : taskHead
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-06-02
|
|
*
|
|
******************************************************************************/
|
|
StandardExtract(*model.TaskHead)
|
|
}
|
|
|
|
/******************************************************************************
|
|
*
|
|
* @Function Name : NewExtractService
|
|
*-----------------------------------------------------------------------------
|
|
*
|
|
* @Description : 创建一个NewExtractService
|
|
*
|
|
* @Return Value : NewExtractService实例
|
|
*
|
|
* @Author : zhangxin
|
|
*
|
|
* @Date : 2021-06-02
|
|
*
|
|
******************************************************************************/
|
|
func NewExtractService() ExtractService {
|
|
return implments.NewExtractServiceImplement()
|
|
}
|