为什么函数在本地工作，但不在数据流中工作？

Question

我试图发布一个请求到谷歌分析与数据流。第一步是从大查询中读取适当的参数—它可以正常工作。接下来是在httppost请求中使用它们。在本地，通过提供显式参数，它可以工作，但在数据流中，它对此步骤不做任何操作。你知道吗

这是我的代码（SendRequests类），其中el-BQ中的每个数据行。你知道吗

class SendRequests(beam.DoFn):
    def __init__(self):
        super(SendRequests, self).__init__()
    def process(self, el):
        conn = httplib.HTTPConnection("www.google-analytics.com")
        params = urllib.urlencode(el)
        conn.request("POST", "/collect", params)
        yield 1

locally:
conn = http.client.HTTPConnection("www.google-analytics.com")
conn.request("POST", "/collect", params)

Answer 1

它可能不是“无所事事”。。。检查日志文件。你知道吗

而且，数据流作业可能仅使用专用IP地址运行。如果不是这样，除非数据流作业和函数位于同一专有网络中，否则函数将无法访问。你知道吗

我不认为你会启用谷歌私人访问，但阅读这篇文章，看看它是否有帮助。。。https://cloud.google.com/vpc/docs/private-access-options

加雷斯