Según su rastreo, su código se está rompiendo en este punto . Como puede ver, procesa el código:
json.dump(row_dict, tmp_file_handle)
tmp_file_handle es un NamedTemporaryFile inicializado
con argumentos de entrada predeterminados, es decir, simula un archivo abierto con w+b modo (y, por lo tanto, solo acepta datos similares a bytes como entrada).
El problema es que en Python 2 todas las cadenas son bytes mientras que en Python 3 las cadenas son textos (codificados por defecto como utf-8 ).
Si abre Python 2 y ejecuta este código:
In [1]: from tempfile import NamedTemporaryFile
In [2]: tmp_f = NamedTemporaryFile(delete=True)
In [3]: import json
In [4]: json.dump({'1': 1}, tmp_f)
Funciona bien.
Pero si abre Python 3 y ejecuta el mismo código:
In [54]: from tempfile import NamedTemporaryFile
In [55]: tmp_f = NamedTemporaryFile(delete=True)
In [56]: import json
In [57]: json.dump({'1': 1}, tmp_f)
---------------------------------------------------------------------------
TypeError Traceback (most recent call last)
<ipython-input-57-81743b9013c4> in <module>()
----> 1 json.dump({'1': 1}, tmp_f)
/usr/local/lib/python3.6/json/__init__.py in dump(obj, fp, skipkeys, ensure_ascii, check_circular, allow_nan, cls, indent, separators, default, sort_keys, **kw)
178 # a debuggability cost
179 for chunk in iterable:
--> 180 fp.write(chunk)
181
182
/usr/local/lib/python3.6/tempfile.py in func_wrapper(*args, **kwargs)
481 @_functools.wraps(func)
482 def func_wrapper(*args, **kwargs):
--> 483 return func(*args, **kwargs)
484 # Avoid closing the file as long as the wrapper is alive,
485 # see issue #18879.
TypeError: a bytes-like object is required, not 'str'
Obtenemos el mismo error que el tuyo.
Esto significa que Airflow todavía no es totalmente compatible con Python 3 (como puede ver en el cobertura de prueba
, el módulo airflow/contrib/operators/mysql_to_gcs.py aún no se ha probado ni en python 2 ni en 3). Una forma de confirmar esto sería ejecutar su código usando python 2 y ver si funciona.
Recomiendo crear una incidencia en su JIRA solicitando portabilidad para ambas versiones de Python.
