blazeでsqliteデータベースに接続します。 df = bz.Data("sqlite:///<mydatabase>)
すべて正常に動作しますが、dfとのやりとりでユーザー定義関数を提供する方法がわかりません。 IPアドレスを含むテキストであるdfにIPという名前の列があります。私はテキスト形式のIPアドレス(x)を取り込み、その/ yサブネットを返す関数toSubnet(x、y)も持っています。例えば:私は彼ら/ 14のサブネットにすべてのIPをマップする場合どのようにsqliteバックエンドでPythonの火災のユーザー定義関数を提供するには?
out = toSubnet('1.1.1.1',24)
out
1.1.1.0/24
は今、私が使用:バックエンドがCSVであるときに動作
df.IP.map(lambda x:toSubnet(x,14),'string')
。しかし、sqliteのバックエンドで私はNotImplementedError
を取得します。 ここに何が問題なのですか?
将来的には、BlazeがUDFをサポートするうえで便利だと思います。その後、ユーザはバックエンドデータセットからより抽象度が高いと感じます。あなたの役に立つ答えに多くの感謝のフィリップ。 – user2923891