STREAMS if stream_from == 'kafka' else stream_from return Observable \ .from_(stream) \ .filter(lambda value: datetime.strptime(value['ts'], ...
確定! 回上一頁