擅长:python、mysql、java
<p>把参数传递给job config,然后用reducer_init中的get_jobconf_value读取它们怎么样?这样,您只需读取一次参数。在</p>
<p>像这样:</p>
<pre><code>from mrjob.compat import get_jobconf_value
class MRDataQuality(MRJob):
def reducer_init(self):
...
self.startDate = get_jobconf_value("my.job.settings.startdate")
self.endDate = get_jobconf_value("my.job.settings.enddate")
def reducer(self, groupId, meterList):
for meterId in meterList:
sys.stderr.write("Querying: " + str(meterId) + "\n")
df = extract_meter_data(table, meterId, self.startDate, self.endDate)
</code></pre>
<p>然后像上面那样在代码中设置参数</p>
^{pr2}$