Golang多平台应用部署托管解决方案插件库go-furnace的使用

简介

Furnace是一个用于AWS CloudFormation、Google Cloud Platform或DigitalOcean托管的Golang解决方案。它利用AWS CloudFormation和CodeDeploy，或GCP的DeploymentManager和Git支持，将应用程序部署到健壮、自愈、冗余的环境中。

主要特性

• 支持AWS、GCP和DigitalOcean多平台部署
• 轻量级配置
• 插件系统支持自定义扩展
• 独立的二进制文件，减小体积
• 与Terraform相比更轻量

安装

安装所有二进制文件

# 下载/克隆最新版本
# 进入go-furnace目录
make install-all

这将安装所有依赖项和二进制文件到$GOPATH/bin目录。

构建命令

# 从根目录运行make
make

为不同环境构建

make linux
make windows

插件系统

Furnace通过HashiCorp的Go-Plugins提供了一个高度可定制的插件系统。插件使用gRPC与Furnace进行本地通信。

插件配置

在yaml文件中配置插件路径：

plugins:
  plugin_path: "./plugins"

如果未提供，默认值为./plugins。

插件类型

支持以下事件的插件：

1. 创建堆栈前：可以停止创建过程
2. 创建堆栈后：例如发送通知
3. 删除堆栈前：可以中止删除
4. 删除堆栈后：例如清理资源

Go插件示例（Slack通知）

package main

import (
	"log"

	fplugins "github.com/go-furnace/go-furnace/furnace-aws/plugins"
	"github.com/go-furnace/sdk"
	"github.com/hashicorp/go-plugin"
)

// SlackPreCreate 实现了furnace PreCreate插件接口
type SlackPreCreate struct{}

// Execute 是插件入口点
func (SlackPreCreate) Execute(stackname string) bool {
	api := slack.New("YOUR_TOKEN_HERE")
	params := slack.PostMessageParameters{}
	channelID, timestamp, err := api.PostMessage("#general", fmt.Sprintf("Stack with name '%s' is Done.", stackname), params)
	if err != nil {
		fmt.Printf("%s\n", err)
		return
	}
	fmt.Printf("Message successfully sent to channel %s at %s", channelID, timestamp)
	return true
}

func main() {
	plugin.Serve(&plugin.ServeConfig{
		HandshakeConfig: fplugins.Handshake,
		Plugins: map[string]plugin.Plugin{
			"slack-furnace-precreate": &sdk.PreCreateGRPCPlugin{Impl: &SlackPreCreate{}},
		},
		GRPCServer: plugin.DefaultGRPCServer,
	})
}

Python插件示例

from concurrent import futures
import sys
import time

import grpc

import furnace_pb2
import furnace_pb2_grpc

from grpc_health.v1.health import HealthServicer
from grpc_health.v1 import health_pb2, health_pb2_grpc

class PreCreatePluginServicer(furnace_pb2_grpc.PreCreateServicer):
    """Implementation of PreCreatePlugin service."""

    def Execute(self, request, context):
        result = furnace_pb2.Proceed()
        result.failed = True

        return result

def serve():
    # 需要构建健康服务以与go-plugin配合工作
    health = HealthServicer()
    health.set("plugin", health_pb2.HealthCheckResponse.ServingStatus.Value('SERVING'))

    # 启动服务器
    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
    furnace_pb2_grpc.add_PreCreateServicer_to_server(PreCreatePluginServicer(), server)
    health_pb2_grpc.add_HealthServicer_to_server(health, server)
    server.add_insecure_port('127.0.0.1:1234')
    server.start()

    # 输出信息
    print("1|1|tcp|127.0.0.1:1234|grpc")
    sys.stdout.flush()

    try:
        while True:
            time.sleep(60 * 60 * 24)
    except KeyboardInterrupt:
        server.stop(0)

if __name__ == '__main__':
    serve()

插件命名规则

• PreCreate: *-furnace-precreate*
• PostCreate: *-furnace-postcreate*
• PreDelete: *-furnace-predelete*
• PostDelete: *-furnace-postdelete*

独立二进制文件

为了减小二进制文件体积，Furnace为每个服务提供独立的二进制文件：

• AWS: furnace-aws
• GCP: furnace-gcp
• DigitalOcean: furnace-do

示例应用

项目提供了一个示例应用在furnace-codedeploy-app文件夹中，以及模板文件在templates文件夹中。