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