我一直在构建用于股票市场分析的大数据应用程序。每天大约5TB的记录。我使用Golang在Cassandra/MySQL中进行数据转换/计算和保存。但是Python有很好的数据分析类库Pandas、Spark等，但是多核处理没有简单的方法，而且需要很多时间。所以，我想在Golang中并发调用python数据分析任务。一种方法是直接执行命令行任务，但我认为应该有更具可扩展性的解决方案。也许有用于Golang和Python之间通信的库。我想也许我应该创建多个PythonFlask服务器并给它们分配任务。速度很重要，但我可以牺牲一些速度来获得简洁的解决方案。有任何想法吗？
我目前从事微服务架构方面的工作。在我将NATS插入我的项目之前，我想用它测试一些简单的场景。在一个场景中，我有一个简单的发布者，它通过在localhost:4222上运行的基本Nats服务器在for循环中发布100.000条消息。最大的问题是订阅者。当他收到30.000-40.000条消息时，我的整个main.go程序和所有其他go例程就会停止，什么也不做。我可以用ctrl+c退出。但发布者仍在继续发送消息。当我打开一个新终端并启动订阅者的一个新实例时，一切都再次运行良好，直到订阅者收到大约30000条消息。最糟糕的是，服务器上甚至没有出现一个错误，也没有日志，所以我不知道发生了什么。
我目前从事微服务架构方面的工作。在我将NATS插入我的项目之前，我想用它测试一些简单的场景。在一个场景中，我有一个简单的发布者，它通过在localhost:4222上运行的基本Nats服务器在for循环中发布100.000条消息。最大的问题是订阅者。当他收到30.000-40.000条消息时，我的整个main.go程序和所有其他go例程就会停止，什么也不做。我可以用ctrl+c退出。但发布者仍在继续发送消息。当我打开一个新终端并启动订阅者的一个新实例时，一切都再次运行良好，直到订阅者收到大约30000条消息。最糟糕的是，服务器上甚至没有出现一个错误，也没有日志，所以我不知道发生了什么。
我知道这个问题有点主观，但我不知道该怎么做。目前我正在使用Go+Go-kit编写一些微服务。我想以集成测试类型的方式测试这些微服务的端点，但我不确定如何去做。我唯一能想到的就是让shell脚本命中端点并检查响应。但这似乎是一种拼凑而不是真正明智的做法。我觉得应该有更好的方法来做到这一点。有人有什么建议吗？ 最佳答案 端到端测试的另一种方法是Consumer-DrivenContract(疾控中心)。虽然进行一些端到端测试很有用，但它们也有一些缺点，例如:消费者服务必须知道如何启动提供者服务。这听起来像是不必要的信息，当服务数量开始增
我知道这个问题有点主观，但我不知道该怎么做。目前我正在使用Go+Go-kit编写一些微服务。我想以集成测试类型的方式测试这些微服务的端点，但我不确定如何去做。我唯一能想到的就是让shell脚本命中端点并检查响应。但这似乎是一种拼凑而不是真正明智的做法。我觉得应该有更好的方法来做到这一点。有人有什么建议吗？ 最佳答案 端到端测试的另一种方法是Consumer-DrivenContract(疾控中心)。虽然进行一些端到端测试很有用，但它们也有一些缺点，例如:消费者服务必须知道如何启动提供者服务。这听起来像是不必要的信息，当服务数量开始增
我正在尝试用Go构建一个微服务架构项目。我目前使用的是支持模块的Go1.11，所以我将根目录放在GOPATH之外的任意目录中。如果我正确理解了微服务架构概念，尽管我的微服务需要独立，但它们可以共享依赖关系(而且我没有看到另一种做事的方式，是吗？)下面是我的目录结构:.├──go.mod├──lambda│ └──account_create│ └──main.go├──readme.md└──types├──account.go├──location.go├──order.go├──pricing.go├──product.go└──types.go现在我期望的行为是能够运行gob
我正在尝试用Go构建一个微服务架构项目。我目前使用的是支持模块的Go1.11，所以我将根目录放在GOPATH之外的任意目录中。如果我正确理解了微服务架构概念，尽管我的微服务需要独立，但它们可以共享依赖关系(而且我没有看到另一种做事的方式，是吗？)下面是我的目录结构:.├──go.mod├──lambda│ └──account_create│ └──main.go├──readme.md└──types├──account.go├──location.go├──order.go├──pricing.go├──product.go└──types.go现在我期望的行为是能够运行gob
我尝试使用go-kit(gokit.io)并使用它构建实际应用程序。我看例子。这些例子很棒。但我不明白如何在go-kit框架中为服务通信/数据传输提供服务。我可以看到“真实世界”的运输应用程序，但我不明白它怎么可能是“真实世界”的微服务。我可以在消息来源中看到，例如，他们构建预订服务只是将外国存储库传递到服务中typeservicestruct{cargoRepositorycargo.RepositorylocationRepositorylocation.RepositoryroutingServicerouting.ServicehandlingEventRepositoryca
我尝试使用go-kit(gokit.io)并使用它构建实际应用程序。我看例子。这些例子很棒。但我不明白如何在go-kit框架中为服务通信/数据传输提供服务。我可以看到“真实世界”的运输应用程序，但我不明白它怎么可能是“真实世界”的微服务。我可以在消息来源中看到，例如，他们构建预订服务只是将外国存储库传递到服务中typeservicestruct{cargoRepositorycargo.RepositorylocationRepositorylocation.RepositoryroutingServicerouting.ServicehandlingEventRepositoryca
我是DevOps的新手，特别是使用golang和微服务架构。我想知道go应用程序是否应该部署在容器(Docker)中。在这种情况下，我有一个使用微服务架构构建的系统。例如，我有2个Web服务，A和B。我还有另一个Web服务器充当这两个服务前面的网关。A和B都需要访问数据库，例如MySQL。A处理A表，B处理B表。我知道在Go中，源代码被编译成一个可执行的二进制文件。因为我这里有3个服务，所以我有3个二进制文件。这三个都作为公开JSONRESTAPI的Web服务器运行。我的问题是:我可以将这些服务器一起部署在一台主机上，该主机在不同端口上运行吗？例如，如果我的主机获得IPx.x.x.x，
