<p>扩展上一个答案:</p>
<p>当前存在一个具有所需功能的函数,以下是来自<a href="https://github.com/GoogleCloudPlatform/google-cloud-python/blob/master/pubsub/google/cloud/gapic/pubsub/v1/subscriber_client.py#L662" rel="nofollow noreferrer">subscriber_client.py</a>的文档:</p>
<pre><code>def pull(self,
subscription,
max_messages,
return_immediately=None,
options=None):
...
Args:
...
return_immediately (bool): If this field set to true, the system
will respond immediately even if
it there are no messages available to return in the ``Pull`` response.
Otherwise, the system may wait (for a bounded amount of time) until at
least one message is available, rather than returning no messages. The
client may cancel the request if it does not wish to wait any longer for
the response.
</code></pre>
<p>但是,首先读取<a href="https://github.com/GoogleCloudPlatform/google-cloud-python/issues/4338#issuecomment-342309349" rel="nofollow noreferrer">this comment</a>的执行返回两个异常(我显示的异常是两个异常的聚合):</p>
<blockquote>
<p>RetryError(Exception occurred in retry method that was not classified
as transient, caused by <_Rendezvous of RPC that terminated with
(StatusCode.INVALID_ARGUMENT, A required argument is missing in the
request: (argument="max_messages").)>)</p>
</blockquote>
<p>如果您需要更多详细信息,可以使用<a href="https://github.com/GoogleCloudPlatform/google-cloud-python/issues/4338#issuecomment-342212239" rel="nofollow noreferrer">related issue</a>。在</p>