Google数据流错误：NameError:未定义全局名称“itertools”

Question

我试图在Google云上运行apachebeam程序。你知道吗

现在，在管道中，我调用join\u lists（）函数 在这个函数中，我使用itertools.产品但我收到了错误信息：

错误消息

NameError: global name 'itertools' is not defined [while running 'FlatMap(join_lists)']

代码

def join_lists((k,v)):
    itertools.product(v['master_data'], v['new_data'])

主要功能：

joined_dicts = (
    {'master_data' :master_data, 'new_data' : new_data }
    | beam.CoGroupByKey()
    | beam.FlatMap(join_lists)
    | 'mergeddicts' >> beam.Map(lambda (masterdict, newdict): new_dict.update(master_dict))
)    

我已经进口了itertools

import itertools