使用GCloud仿真器的Google Cloud PubSub V1

Question

Google::Cloud::Pubsub.new(project: project_id, emulator_host: emulator_host)

PublisherServiceApiClient publisherClient = PublisherServiceApiClient.Create();
PublisherClient publisher = PublisherClient.Create(...)

'PublisherClient'不包含'Create'的定义。

相反，我得到了createasync，其中包含topicname、publisherclient.clientCreationSettings和publisherclient.settings。

https://googleapis.github.io/google-cloud-dotnet/docs/google.cloud.pubsub.v1/api/google.cloud.pubsub.v1.publisherclient.html

以一个实际的问题来结束，目前如何在云中使用.NET for实现云PubSub，然后在本地使用模拟器实现云PubSub？此外，我是否使用了错误的库或错误的文档？

任何建议、指示或忠告都将不胜感激。

Answer 1

emulatorAddr = Environment.GetEnvironmentVariable("PUBSUB_EMULATOR_HOST");
if (emulatorAddr != null)
{
    channel = new Channel(emulatorAddr, ChannelCredentials.Insecure);
    pub = PublisherServiceApiClient.Create(channel);
}
else
{
    pub = PublisherServiceApiClient.Create();
}

PubsubMessage msg = new PubsubMessage
{
    Data = ByteString.CopyFromUtf8(JsonConvert.SerializeObject(payload))
};

pub.PublishAsync(topic, new[]{ msg });