bug fix: etl & logger

2 months ago · a4b4a453bb
parent a022bdf92f
commit a4b4a453bb
1 changed files with 4 additions and 1 deletions
--- a/transport/iowrapper.py
+++ b/transport/iowrapper.py
@ -283,7 +283,10 @@ class IETL(BaseIO) :
            if hasattr(writer._agent,'_table'):
                _input['table'] = writer._agent._table
 
-            
+            for _item in _schema :
+                if _item['type'] in ['INTEGER','BIGINT','INT'] :
+                    _column  = _item['name']
+                    _data[_column] = _data[_column].copy().fillna(0).astype(np.int64)
            writer.write(_data,schema=_schema)
        except Exception as e:
            _action = 'post-error'